Javaのスレッドを2つのスレッドから通知を受け取るようにするには？

Question

私は、複数のスレッドを持つプログラムを書いています。そのプログラムの中で 私はしばしばwaitとnotifyを使って、あるスレッドが他のスレッドが起動するまで待つようにします。

私の想像上のプロジェクトでは、私は3つのスレッドがあると言うことができます：m、aとb。 mはメインです。 mスレッドはスレッドを開始し、bスレッドを開始します。 mスレッドはあるスレッドがそのジョブで完了するのを待つべきです（死ぬことはしません）。もし完了すれば、目覚めて一つのことをしなければならない。 bが完了すれば、目覚めて別のことをするべきです。このような

と何かを：：

私がmでこのようなものを使用することができ、私はBを待ちたい場合

synchronized(this) 
{ 
    notify(); 
} 

同じことが行きます。

synchronized(this) 
{ 
    notify(); 
} 

しかし、私はそれらの両方を待ちたい場合、私はこのようなコード必要があります：

Bで

synchronized(b) 
{ 
    b.wait(); 
} 

：メートルで

synchronized(a, b) 
{ 
    a,b.wait(); 
} 

もちろんのを、これはjavaではサポートされていません。

もちろん、メインをスリープ状態（32）にしたり、そのようなものを入れて、フラグをaとbに入れたり、起きるとフラグをチェックしたり、どちらが終了したかを知ることができます。 しかし、私はwait-notifyアプローチを使って、aとbのフラグを常にチェックすることを避けたかったのです。

だから、解決策は何ですか？ 何か方法がありますが、フラグが常にチェックされている以外、mからaまたはbが終了した（死んでいない）ことがわかりましたか？

Answer 1

メインスレッドmを持つためには反応します。

最も簡単な例では、mは依存するスレッドをリストに保持し、2つのループで最初に他のスレッドを開始した後、別のループでそのスレッドが終了するまで待機します。java.util.concurrent.BlockingQueue

ほとんど同じ使用を使用して

• メッセージは、スレッド間を通過する：このような何かを達成するために利用できる他のソリューションの多くがあります

  public class MainThread { 
      public void run() { 
       List<Thread> threads = Arrays.asList(
        new Thread(() -> react(this)), 
        new Thread(() -> react(this)), 
       ); 
       // start all threads first to avoid deadlock 
       threads.forEach(Thread::start); 
       // wait for all threads to finish in order 
       threads.forEach(Thread::join); 
       // here you can do whatever post steps you want 
      } 
      public void react(Thread t) { 
       System.out.print("MainThread called by " + t); 
      } 
  } 
  

  ：だから、あなたは、このような何かを持っている必要があります大文字小文字の区別がある場合java.util.concurrent.CountdownLatch

• @ john16384最終結果をキャッチ/最終値を返すことが重要でない場合は、java.util.concurrent.CompletableFuture

など。

Answer 2

共有オブジェクトに対して同期（待機、通知）を実行できます。多分私は？代わりにaまたは完全なbは、ちょうどaを持っているとbが正しいことを行うときmは物事を行うことの

Answer 3

。

私はCompletableFutureでこれをやってお勧めします：子スレッド（この場合aとbで）のいずれかが、いくつかのオプションがあります作業終了後

CompletableFuture.runAsync(<thread A>) 
    .thenRun(<stuff that should be done after A completes>); 

Answer 4

あなたの文脈では、CompletableFutureを使用して目的を果たします。