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

Object

Exchanger

属性

RegisterAttribute JavaTypeParametersAttribute

注解

一个同步点，线程可以在配对中配对和交换元素。 每个线程在方法的条目 #exchange exchange 上呈现一些对象，与伙伴线程匹配，并在返回时接收其合作伙伴的对象。 交换器可以被视为双向形式 SynchronousQueue。 交换器在基因算法和管道设计等应用程序中可能很有用。

<b>示例用法：</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对成功交换对象的线程，在每个线程<之前（发生在之前<>/i>）中的操作exchange()，这些线程随后从另一个线程中的相应exchange()线程返回。

在 1.5 中添加。

Java文档java.util.concurrent.Exchanger。

本页的某些部分是根据 创建和共享的工作进行的修改，并根据 许可证中所述的条款使用。