Java中类Exchaner浅析
Exchaner用于实现两个人之间的数据交换,每个人在完成一定的事物后想与对方交换数据,第一个先拿出数据的人将一直等待第二个人拿着数据到来时,才能彼此交换数据。
张孝祥老师在讲解Exchaner时的比喻:
好比两个毒贩要进行交易,一手交money,一手交drug,不管谁先来到接头地点后,就处于等待状态了,当另外一方也到达接头地点(所谓到达接头地点,也就是到达了准备街头的状态)时,两者的数据就立即交换了,然后就可以各忙各的了。
实例代码如下和运行结果如下:
package com.lianxi.wanghao; import java.util.concurrent.Exchanger; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; public class ExchangerTest { public static void main(String [] args){ ExecutorService service=Executors.newCachedThreadPool(); final Exchanger<String> exchanger=new Exchanger<String>(); service.execute(new Runnable(){ public void run(){ try { String data1="money"; System.out.println("线程"+Thread.currentThread().getName()+"正在把数据"+data1+"换出去"); Thread.sleep((long)(Math.random()*10000)); String data2=(String)exchanger.exchange(data1); System.out.println("线程"+Thread.currentThread().getName()+"换回数据为"+data2); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } } }); service.execute(new Runnable(){ public void run(){ try { String data1="drug"; System.out.println("线程"+Thread.currentThread().getName()+"正在把数据"+data1+"换出去"); Thread.sleep((long)(Math.random()*10000)); String data2=(String)exchanger.exchange(data1); System.out.println("线程"+Thread.currentThread().getName()+"换回数据为"+data2); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } } }); } }
运行结果:
线程pool-1-thread-1正在把数据money换出去
线程pool-1-thread-2正在把数据drug换出去
线程pool-1-thread-2换回数据为money
线程pool-1-thread-1换回数据为drug
郑重声明:本站内容如果来自互联网及其他传播媒体,其版权均属原媒体及文章作者所有。转载目的在于传递更多信息及用于网络分享,并不代表本站赞同其观点和对其真实性负责,也不构成任何其他建议。