并发编程之Exchanger-线程间交换数据

concurrent包中的Exchager类，主要用于两个线程间的数据通信（只适用于两个线程），或者说就是两个线程交换数据。Exchanger提供了一个同步点，当线程A调用exchange()方法时，会进入阻塞状态，直到第二个线程也调用exchange()方法后，就到达了同步点，此时就可以将两个线程各自的数据进行传递。

publicclassExchangerTest {

privatestaticExecutorService executorService = Executors.newFixedThreadPool(2);

privatestaticfinalExchanger exchanger =newExchanger();

publicstaticvoidmain(String[] args) {

executorService.execute(newRunnable() {

@Override

publicvoidrun() {

try{

String X ="abc";

String exchange = exchanger.exchange(X);

}catch(InterruptedException e) {

e.printStackTrace();

}

}

});

executorService.execute(newRunnable() {

@Override

publicvoidrun() {

try{

String Y ="def";

String exchange = exchanger.exchange(Y);

}catch(InterruptedException e) {

e.printStackTrace();

}

}

});

executorService.shutdown();

}

}

/**输出结果**/

Y=abc

X=def

Exchanger适用于遗传算法、生产消费者模式功能里面，平时项目开发的话我也用的比较少。