并发编程之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适用于遗传算法、生产消费者模式功能里面,平时项目开发的话我也用的比较少。

  • 发表于:
  • 原文链接https://kuaibao.qq.com/s/20180614G147ZA00?refer=cp_1026
  • 腾讯「云+社区」是腾讯内容开放平台帐号(企鹅号)传播渠道之一,根据《腾讯内容开放平台服务协议》转载发布内容。
  • 如有侵权,请联系 yunjia_community@tencent.com 删除。

扫码关注云+社区

领取腾讯云代金券