Exchanger クラス

定義

[Android.Runtime.Register("java/util/concurrent/Exchanger", DoNotGenerateAcw=true)]
[Java.Interop.JavaTypeParameters(new System.String[] { "V" })]
public class Exchanger : Java.Lang.Object

[<Android.Runtime.Register("java/util/concurrent/Exchanger", DoNotGenerateAcw=true)>]
[<Java.Interop.JavaTypeParameters(new System.String[] { "V" })>]
type Exchanger = class
    inherit Object

継承

Object

JavaObject

Object

Exchanger

属性

RegisterAttribute JavaTypeParametersAttribute

注釈

スレッドがペア内の要素をペアにしてスワップできる同期ポイント。 各スレッドは、 #exchange exchange メソッドへのエントリでオブジェクトを提示し、パートナー スレッドと一致し、返されたパートナーのオブジェクトを受け取ります。 交換体は、 SynchronousQueueの双方向形式として見ることができます。 交換体は、遺伝的アルゴリズムやパイプライン設計などのアプリケーションで役立つ場合があります。

<b>Sample Usage:</b>Exchanger を使用してスレッド間でバッファーをスワップするクラスのハイライトを次に示します。バッファーを満たすスレッドは、必要なときに空にしたばかりのものを取得し、バッファーを空にするスレッドに渡します。

{@code
            class FillAndEmpty {
              Exchanger<DataBuffer> exchanger = new Exchanger<>();
              DataBuffer initialEmptyBuffer = ...; // a made-up type
              DataBuffer initialFullBuffer = ...;

              class FillingLoop implements Runnable {
                public void run() {
                  DataBuffer currentBuffer = initialEmptyBuffer;
                  try {
                    while (currentBuffer != null) {
                      addToBuffer(currentBuffer);
                      if (currentBuffer.isFull())
                        currentBuffer = exchanger.exchange(currentBuffer);
                    }
                  } catch (InterruptedException ex) { ... handle ...}
                }
              }

              class EmptyingLoop implements Runnable {
                public void run() {
                  DataBuffer currentBuffer = initialFullBuffer;
                  try {
                    while (currentBuffer != null) {
                      takeFromBuffer(currentBuffer);
                      if (currentBuffer.isEmpty())
                        currentBuffer = exchanger.exchange(currentBuffer);
                    }
                  } catch (InterruptedException ex) { ... handle ...}
                }
              }

              void start() {
                new Thread(new FillingLoop()).start();
                new Thread(new EmptyingLoop()).start();
              }
            }}

メモリ整合性効果: Exchangerを介してオブジェクトを正常に交換するスレッドのペアごとに、各スレッド内の exchange() の前のアクション <i>happen-before</i> 他のスレッドの対応する exchange() からの戻り値に続くアクションです。

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

Javaドキュメント。

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