java.util.concurrent

3熱

1答えて

私は3つのWebサービスコールを並行して実行できます。したがって、私はそれらを実行する3スレッドの固定プールを使用しています。ここでは、最初の3つの呼び出しが処理された後にのみ、並列に実行できる2つ以上のWebサービス呼び出しを処理します。どうすればそれらをバッチすることができますか？バッチ内のものを並行して実行したい。また、すべてのバッチは、前のバッチが完了した後にのみ実行されます。これま

0熱

1答えて

ThreadPoolExecutorのcorePoolSizeを動的に変更する

4つのCPUを持つマシンでスレッドプールが実行されていて、このプールに負荷動的制御を実行したいとします。プール内でスレッドが実行されているときにcorePoolSizeを変更することは可能でしょうか？つまり、負荷が低い場合は、最大で2つのスレッドを同時に実行できますが、負荷が高い場合は4つのスレッドが許可されます。そうでない場合は、適切な解決策はありますか？

2熱

1答えて

ConcurrentHashMapsでアトミックネストされた反復操作を行う方法は？

は私が持っている他のオブジェクト（sessionCollection）が含まれていて、私は次の反復操作を行う必要がありConcurrentHashMapサブスクリプション：sessionCollection.removeAllSubscriptionsOfSessionは内部（もConcurrentHashMap）のコレクションを介して別の反復操作を行い subscriptions.values(

2熱

3答えて

同期ロックを使用すると困惑します

以下のコードを参照してください。これはDynamicPropertyFactoryクラスで、ConfigurationManager.classをロックします。私の理解では、ロックはクラスまたはインスタンス自体でのみ機能します。これを理解するには？私の理解として public class *DynamicPropertyFactory*{ public static *DynamicP

0熱

1答えて

、オブジェクト

私は次のような出力を実現するためにどのように少し混乱していますのキューで地図を実装する方法を { "finalOutput":{["test":{[],[],[],[],[],[],[],[],[],[]}, "test1":{[],[],[]....[]}, "test2":{[],[]....[]}]} } 。この出力では、1つのキーにキュー概念を持つ10

0熱

1答えて

Duration.Infで待っているインスタンスをブロックするのがベストプラクティスですか？

私たちは、コードのこの部分を知っていた：私は3秒と言う期間の有限値を入れた場合 Await.result(someFuture, Duration.Inf) 、一度期限が切れ、それはTimeOutExceptionをスローします。 Duration.Infについては、アプリケーションがハングすることがありますか？ Duration.Infを使用する際のベストプラクティスは何ですか？

0熱

2答えて

AtomicMarkableReferenceコンカレント・アンド・セット・メソッドと取得メソッドの同時アクセス

JavaののcompareAndSet()メソッドは原子的に動作します。したがって、同じオブジェクトに対して同時に2つのメソッドを実行することはできません。しかし、スレッドの1つがcompareAndSet()メソッドを実行していて、もう1つがget()またはgerReference()メソッドを同じオブジェクトで同時に実行している場合は、compareAndSet()メソッドが完了するまでこれら

1熱

1答えて

オブジェクトのfinalとしてフィールドを作成すると、そのオブジェクトのnull参照を参照するスレッドは避けられますか？

Practice-でのJava並行処理から抽象/スニペット // Unsafe publication public Holder holder; public void initialize(){ holder = new holder(42); } 2つのことは、不適切に発行されたオブジェクトと間違って行くことができます。他のスレッドはホルダーフィールドの無効な値を参照

0熱

1答えて

非同期処理のために短命のExecutorService

私は、非同期要求をファイアー・アンド・ファッションで実行できるメソッドを持っています。方法は、次のように実装されています private void publishWorkItem(final Object payload, final ZkWorkCompleteCallback callback) { if (payload == null) throw new Nul

0熱

1答えて

Androidでアクティビティ間でConcurrentLinkedQueueを共有

私は、複数のアクティビティで共有される4つのバイトのキューを必要とするアプリケーションに取り組んでいます。私はIOIO OTG上の2つのUARTと通信するため、それらを非ブロッキングにしたいので、ConcurrentLinkedQueueを使用しています。キュー内のデータは、初期化されている同じメソッド内に置くことしかできないようですが、コントロールが別のメソッドに渡されるとサイズは0になります。