java.util.concurrent

1熱

3答えて

特定の時間（つまり10秒）まで最大Nの要素を格納するキューを探します。満杯の場合は最も古い値を廃棄する必要があります。生存時間の面を見逃しているApache Collections（CircularFifoQueueJavaDoc）に同様のキューが見つかりました。完全なメッセージブローカーは私の小規模プロジェクトのオーバーヘッドのようです。私はこれをどのように実装すべきかというヒントを教えてく

1熱

2答えて

ツリー内のすべてのスレッドを停止するには？

メインスレッドでExecutorService.shutdownNow（）を実行しても、すべてのスレッドが停止するわけではありませんが、Thread1またはThread2でExecutorService.shutdownNow（）を実行するとサブスレッドが終了しますシャットダウンコマンドを最下位レベルにカスケードする方法はありますか？ Main thread / \ /

2熱

1答えて

JavaのAtomicMarkableReferenceの "get"メソッド実装の背後にある理由は何ですか？

JavaでAtomicMarkableReferenceを使用して、マークビットとともにオブジェクト参照をアトミックに更新することができます。 javadoc状態：実装注：この実装は、「箱入り」[参照、ブール]ペアを表す内部オブジェクトを作成することにより、マーキングの参照を維持します。これは、クラスのJavaの8ソースコードで見ることができるかに応じて真である：クラスのget方法の設計の背後

0熱

1答えて

ReentrantLockがSpringXDで動作しない理由

私はSpringXDでの作業にReentrantLockを追加しようとしていますが、時にはスレッド間に中断があるようです。例えば、私はこれらのコードを持っている： public class LoadGenerator extends MessageProducerSupport { private final AtomicBoolean running = new AtomicBoolean

4熱

1答えて

Redis dequeueの 'parking to wait'状態のスレッド

複数のスレッドを実行するtomcat-spring4.2アプリケーションがあります。各スレッドは1つのキューからデキューしますが、キューには複数のスレッドが割り当てられています。状況はうまく始まりますが、数時間/〜500kのデキュー操作後、スレッドは非常に遅い速度でデキューします。私はオレンジ色、すなわち公園のスレッドを参照してくださいjvisualvmで次のようにスレッドダンプは次のとおり

2熱

1答えて

Javaサーブレットブラウザプッシュ通知のアーキテクチャ

Google Cloud MessagingとFirefox Push Notification Systemを介してブラウザプッシュ通知の送信を実装しています。このためには、GCMとFPNSへのHTTP投稿リクエストを作成する必要があります。 GCM/FPNSにHTTPリクエストを行うには、ユーザー登録IDが必要です。 JavaScriptを使用して、登録IDを収集し、それをCassandraに

0熱

1答えて

使用

私はFutures よう List<Future<String>> results = executorService.invokeAll(tasks); または Future<String> res = executorService.submit(new SingleWorker()); System.out.println(res.get()); を使用していた場合、システムが完了

0熱

1答えて

javaを使用するときにスレッドがスタックするConcurrentSkipListSetメソッドを追加する

ConcurrentSkipListSetコレクションを使用して、並行演算子を処理しています。設定はサポートしていないので、それはおそらく、ほかに、他のコンパレータのカスタムソートデータ方式を立ち往生 import java.util.Comparator import java.util.concurrent._ object SetDeadLock extends App {

0熱

1答えて

ExecutorService内のグループスレッド

ExecutorServiceでは、特定のコースIDを処理するすべてのスレッドをグループ化し、そのコースIDを1つのスレッドが処理し終えると、そのコースIDの処理中にある他のスレッドをすべて閉じることができますか？ 1つのスレッド終了プロセスまでコースidを処理できるスレッドの数は固定数ではありません。更新：だから、任意のスレッドがこのコースを処理するために入力して、私は静的なコレクションに追

0熱

2答えて

実行可能オブジェクトをExecutorServiceに提出した後で実行可能オブジェクトを変更しますか？

Executableサービス（アンバウンド・キューを持つシングル・スレッド）に実行可能オブジェクトをサブミットした後、その実行可能オブジェクトを変更できますか？例えば：あなたは上記の例でわかるように、我々は実行可能なオブジェクトを提出し、あまりにもループ内のオブジェクトの内容を変更する場合 public class Test { @Autowired private Runn