CyclicBarrier クラス

定義

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

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

継承

Object

JavaObject

Object

CyclicBarrier

属性

RegisterAttribute

注釈

一連のスレッドが互いに共通のバリア ポイントに到達するまで待機できるようにする同期支援。 CyclicBarriers は、スレッドの固定サイズのパーティを含むプログラムで役立ちます。これは、お互いを待つ必要がある場合があります。 バリアは、待機中のスレッドが解放された後に再利用できるため、 <em>cyclic</em> と呼ばれます。

CyclicBarrierでは、パーティの最後のスレッドが到着した後、スレッドが解放される前に、バリア ポイントごとに 1 回実行されるオプションの Runnable コマンドがサポートされます。 この <em>barrier アクション</em> は、いずれかの当事者が続行する前に共有状態を更新する場合に便利です。

<b>サンプル使用法:</b> 並列分解設計でバリアを使用する例を次に示します。

{@code
            class Solver {
              final int N;
              final float[][] data;
              final CyclicBarrier barrier;

              class Worker implements Runnable {
                int myRow;
                Worker(int row) { myRow = row; }
                public void run() {
                  while (!done()) {
                    processRow(myRow);

                    try {
                      barrier.await();
                    } catch (InterruptedException ex) {
                      return;
                    } catch (BrokenBarrierException ex) {
                      return;
                    }
                  }
                }
              }

              public Solver(float[][] matrix) {
                data = matrix;
                N = matrix.length;
                Runnable barrierAction = () -> mergeRows(...);
                barrier = new CyclicBarrier(N, barrierAction);

                List<Thread> threads = new ArrayList<>(N);
                for (int i = 0; i < N; i++) {
                  Thread thread = new Thread(new Worker(i));
                  threads.add(thread);
                  thread.start();
                }

                // wait until done
                for (Thread thread : threads)
                  try {
                    thread.join();
                  } catch (InterruptedException ex) { }
              }
            }}

ここでは、各ワーカー スレッドがマトリックスの行を処理し、すべての行が処理されるまでバリアで待機します。 すべての行が処理されると、指定された Runnable バリア アクションが実行され、行がマージされます。 合併によってソリューションが見つかったと判断された場合、 done() は true を返し、各ワーカーは終了します。

バリア アクションが実行時に中断されているパーティに依存しない場合、パーティ内のスレッドは、解放されたときにそのアクションを実行できます。 これを容易にするために、 #await を呼び出すたびに、バリアにあるそのスレッドの到着インデックスが返されます。 その後、バリア アクションを実行するスレッドを選択できます。次に例を示します。

{@code
            if (barrier.await() == 0) {
              // log the completion of this iteration
            }}

CyclicBarrierでは、同期試行の失敗に対してすべてまたはなし破損モデルが使用されます。中断、障害、タイムアウトのためにスレッドが途中でバリア ポイントを離れると、そのバリア ポイントで待機している他のすべてのスレッドも、BrokenBarrierException経由で異常に残ります (または、ほぼ同時に中断された場合はInterruptedException)。

メモリ整合性の効果: バリア アクションの一部である await()<i>happen-before</i> アクションを呼び出す前のスレッド内のアクション。その後、他のスレッドの対応するから正常に戻った後にawait()アクション。

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

Javaドキュメント。

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