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适用于遗传算法、生产消费者模式功能里面,平时项目开发的话我也用的比较少。
领取专属 10元无门槛券
私享最新 技术干货