Exchanger——Java两个线程间交换数据的工具类

摘要: 介绍java多线程工具类Exchanger的简单使用。

Exchanger是一个用于线程间数据交换的协作工具类，它提供一个同步点，两个线程可以交换彼此的数据，注意这里只能是两个线程。

两个线程通过exchange() 方法来交换数据，当第一个线程执行到exchange()时，会产生阻塞，直到另一个线程也执行exchange(),之后两个线程都可以得到对方的执行结果。示例代码如下：

public class ExchangerTest {
private static final Exchanger<String> exgr = new Exchanger<String>();

private static ExecutorService threadPool = Executors.newFixedThreadPool(2);

public static void main(String[] args) {
threadPool.execute(new Runnable(){
@Override
public void run() {
try {
String A = "this is a A";
String B = exgr.exchange(A);
System.out.println("a 线程里 a:"+A+" b:"+B);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
});

threadPool.execute(new Runnable(){
@Override
public void run() {
try {
String B = "this is a B";
String A = exgr.exchange(B);
System.out.println("B 线程里 a:"+A+" b:"+B);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
});

threadPool.shutdown();
}
}

执行结果：

B 线程里 a:this is a A b:this is a B
a 线程里 a:this is a A b:this is a B

如果两个线程有一个一直没有执行exchange()方法，则会一直等待，如果要避免一直等待，可以使用exchange(V x,long timeout,TimeUnit unit)设置最大等待时长。