java并发编程之Exchanger

Exchanger<V>

V - 可以交换的对象类型

可以在对中对元素进行配对和交换的线程的同步点。每个线程将条目上的某个方法呈现给 exchange 方法，与伙伴线程进行匹配，并且在返回时接收其伙伴的对象。Exchanger 可能被视为 SynchronousQueue 的双向形式。Exchanger 可能在应用程序（比如遗传算法和管道设计）中很有用。

这个实现的是两个线程之间的一个信息交流

public class TestExchanger
{
public static void main(String[] args)
{
System.out.println("Hello World!");
final Exchanger<List<Integer>> exchanger = new Exchanger<List<Integer>>();
new Thread(){
@Override
public void run(){
List<Integer> l = new ArrayList<Integer>();
l.add(1);
l.add(2);
try{
System.out.println(Thread.currentThread().getName()+":"+l);
l = exchanger.exchange(l);
}catch(InterruptedException ex){
ex.printStackTrace();
}
System.out.println(Thread.currentThread().getName()+":"+l);
}
}.start();

new Thread(){
@Override
public void run(){
List<Integer> l = new ArrayList<Integer>();
l.add(3);
l.add(4);
try{
System.out.println(Thread.currentThread().getName()+":"+l);
Thread.sleep(2000);
l = exchanger.exchange(l);
}catch(InterruptedException ex){
ex.printStackTrace();
}
System.out.println(Thread.currentThread().getName()+":"+l);
}
}.start();
}
}

添加一个Thread.sleep()之后就会发现，两个线程交换信息结束才能同时向下执行