compact1, compact2, compact3

java.util.concurrent

Class Exchanger<V>

java.lang.Object

java.util.concurrent.Exchanger<V>

参数类型

V -可交换的对象的类型

public class Exchanger<V>
extends Object

线程可以对的同步点和对中的元素交换元素的同步点。每一个线程进入 exchange方法提出了一些目标，与合作伙伴的线匹配，并接收其伴侣的对象返回。交换机可以被看作是一个双向的 SynchronousQueue形式。交换器等应用遗传算法和管道的设计是有用的。

示例用法：这里是一个类使用一个Exchanger交换缓冲区之间的螺纹，螺纹填充缓冲区获取一个刚倒一的时候需要它的亮点，把填充一个线程清空缓冲区。

 class FillAndEmpty {
   Exchanger<DataBuffer> exchanger = new Exchanger<DataBuffer>();
   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()每个线程happen-before那些从其他线程对应的exchange()返回后续。

从以下版本开始：

一点五

构造方法摘要

构造方法

Constructor and Description
Exchanger() 创建一个新的交换机。

方法摘要

Modifier and Type	Method and Description
V	exchange(V x) 等待另一个线程到达这个交换点（除非当前线程 interrupted），然后将给定对象，回报的对象。
V	exchange(V x, long timeout, TimeUnit unit) 等待另一个线程到达这个交换点（除非当前线程 interrupted或指定的等待时间的流逝），然后将给定对象，回报的对象。

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Exchanger

public Exchanger()

创建一个新的交换机。

方法详细信息

exchange

public V exchange(V x)
           throws InterruptedException

等待另一个线程到达这个交换点（除非当前线程 interrupted），然后将给定对象，回报的对象。

如果另一个线程已经在交换点等待，那么它被恢复为线程调度的目的，并接收通过当前线程传递的对象。当前线程立即返回，接收通过该其他线程传递给该对象的对象。

如果没有其他线程已经在交换中等待，那么当前线程被禁用的线程调度的目的，并处于休眠状态，直到两个事情发生：

• 其他一些线程进入交换；或
• 其他某个线程interrupts当前线程。

如果当前线程：

• 在该方法的入口上有它的中断状态；或
• 是interrupted等待交换，

然后 InterruptedException投入和当前线程的中断状态被清除。

参数

x -交换的对象

结果

由其他线程提供的对象

异常

InterruptedException -如果当前线程被中断等待

exchange

public V exchange(V x,
                  long timeout,
                  TimeUnit unit)
           throws InterruptedException,
                  TimeoutException

等待另一个线程到达这个交换点（除非当前线程 interrupted或指定的等待时间的流逝），然后将给定对象，回报的对象。

如果另一个线程已经在交换点等待，那么它被恢复为线程调度的目的，并接收通过当前线程传递的对象。当前线程立即返回，接收通过该其他线程传递给该对象的对象。

如果没有其他线程已经在交换中等待，那么当前线程被禁用的线程调度的目的，并处于休眠状态，直到三个事情发生：

• 其他一些线程进入交换；或
• 其他某个线程interrupts当前线程；或
• 指定的等待时间的流逝。

如果当前线程：

• 在该方法的入口上有它的中断状态；或
• 是interrupted等待交换，

然后 InterruptedException投入和当前线程的中断状态被清除。

如果指定的等待时间的流逝，然后TimeoutException抛出。如果时间小于或等于零，该方法将不会等待在所有。

参数

x -交换的对象

timeout -最大等待时间

unit的 timeout争论的时间单位

结果

由其他线程提供的对象

异常

InterruptedException -如果当前线程被中断等待

TimeoutException -如果指定的等待时间的流逝，另一个线程进入交换之前