CountDownLatch クラス

定義

[Android.Runtime.Register("java/util/concurrent/CountDownLatch", DoNotGenerateAcw=true)]
public class CountDownLatch : Java.Lang.Object

[<Android.Runtime.Register("java/util/concurrent/CountDownLatch", DoNotGenerateAcw=true)>]
type CountDownLatch = class
    inherit Object

継承

Object

JavaObject

Object

CountDownLatch

属性

RegisterAttribute

注釈

1 つ以上のスレッドが、他のスレッドで実行されている一連の操作が完了するまで待機できるようにする同期支援。

CountDownLatchは、特定の <em>count</em> で初期化されます。 #await await メソッドは、#countDown メソッドの呼び出しにより現在のカウントが 0 に達するまでブロックされ、その後、待機しているすべてのスレッドが解放され、後続の呼び出し#await awaitすぐに戻ります。 これは一発の現象です。カウントをリセットすることはできません。 カウントをリセットするバージョンが必要な場合は、 CyclicBarrierの使用を検討してください。

CountDownLatchは汎用性の高い同期ツールであり、さまざまな目的で使用できます。 カウント 1 で初期化された CountDownLatch は、単純なオン/オフ ラッチまたはゲートとして機能します。 #await await 呼び出すすべてのスレッドは、 #countDownを呼び出すスレッドによって開かれるまでゲートで待機します。 CountDownLatchem<N>/em< に初期化された>を使用すると<em>N</em>スレッドが何らかのアクションを完了するか、何らかのアクションが N 回完了するまで 1 つのスレッドを待機させることができます。

CountDownLatchの便利なプロパティは、countDown呼び出すスレッドがカウントが 0 に達するまで待機する必要がないという点です。これにより、すべてのスレッドが#await awaitを超えてすべてのスレッドが通過するのを防ぐことができます。

<b>サンプル使用法:</b> ワーカー スレッドのグループが 2 つのカウントダウン ラッチを使用するクラスのペアを次に示します。 <ul><li>最初は、ドライバーが続行する準備ができるまでワーカーが進まない開始シグナルです。 <li>2 つ目は、ドライバーがすべてのワーカーが完了するまで待機できるようにする完了シグナルです。 </ul>

{@code
            class Driver { // ...
              void main() throws InterruptedException {
                CountDownLatch startSignal = new CountDownLatch(1);
                CountDownLatch doneSignal = new CountDownLatch(N);

                for (int i = 0; i < N; ++i) // create and start threads
                  new Thread(new Worker(startSignal, doneSignal)).start();

                doSomethingElse();            // don't let run yet
                startSignal.countDown();      // let all threads proceed
                doSomethingElse();
                doneSignal.await();           // wait for all to finish
              }
            }

            class Worker implements Runnable {
              private final CountDownLatch startSignal;
              private final CountDownLatch doneSignal;
              Worker(CountDownLatch startSignal, CountDownLatch doneSignal) {
                this.startSignal = startSignal;
                this.doneSignal = doneSignal;
              }
              public void run() {
                try {
                  startSignal.await();
                  doWork();
                  doneSignal.countDown();
                } catch (InterruptedException ex) {} // return;
              }

              void doWork() { ... }
            }}

もう 1 つの一般的な使用方法は、問題を N 個の部分に分割し、その部分を実行してラッチでカウントダウンする Runnable で各部分を記述し、すべての実行可能ファイルを Executor にキューに入れる方法です。 すべてのサブ部分が完了すると、調整スレッドは await を通過できるようになります。 (この方法でスレッドを繰り返しカウントダウンする必要がある場合は、代わりに CyclicBarrierを使用します)。

{@code
            class Driver2 { // ...
              void main() throws InterruptedException {
                CountDownLatch doneSignal = new CountDownLatch(N);
                Executor e = ...;

                for (int i = 0; i < N; ++i) // create and start threads
                  e.execute(new WorkerRunnable(doneSignal, i));

                doneSignal.await();           // wait for all to finish
              }
            }

            class WorkerRunnable implements Runnable {
              private final CountDownLatch doneSignal;
              private final int i;
              WorkerRunnable(CountDownLatch doneSignal, int i) {
                this.doneSignal = doneSignal;
                this.i = i;
              }
              public void run() {
                doWork();
                doneSignal.countDown();
              }

              void doWork() { ... }
            }}

メモリ整合性の影響: カウントが 0 になるまで、別のスレッドの対応するcountDown()から正常に戻った後に、<>i<happen-before>/iawait() アクションを呼び出す前のスレッド内のアクション。

1\.5 で追加されました。

Javaドキュメント。

このページの一部は、によって作成および共有され、に記載されている条件に従って使用される作業に基づく変更です。