Exchanger
用于实现两个人之间的数据交换,每个人在完成一定的事务后想与对方交换数据,
第一个先拿出数据的人将一直等待第二个人拿着数据到来时,才能彼此交换数据。
比喻:
好比两个毒贩要进行交易,一手交钱,一手交货,不管谁先来到接头地点,都要处于等待
状态,当另一方也到达了接头地点(所谓到达接头地点,也就到达了准备接头的状态)时,
两者的数据立即交换了,然后又可以各忙各的了。
exchange方法就相当与两手高高举着等待交换物,等待人家前来交换,一旦人家到来(即人家
也执行到exchange方法),则两者立马完成数据的交换。
例子:
package cn.edu.hpu.test;
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 exchanger=new Exchanger();
service.execute(new Runnable(){
public void run() {
try {
String data1="123";
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) {
e.printStackTrace();
}
}
});
service.execute(new Runnable(){
public void run() {
try {
String data1="456";
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) {
e.printStackTrace();
}
}
});
}
}
首先利用Executors创建了一个缓存线程池(大小自适应),然后创建了一个交换对象,
之后执行两个线程,分别拿着数据准备交换,当两个线程都执行完exchange(xxx)方法之后,
就完成了交换动作,之后线程可以继续干各自的事情。
结果:
![](https://img.laitimes.com/img/_0nNw4CM6IyYiwiM6ICdiwiIyVGduV2QvwVe0lmdhJ3ZvwFM38CXlZHbvN3cpR2Lc1TPB10QGtWUCpEMJ9CXsxWam9CXwADNvwVZ6l2c052bm9CXUJDT1wkNhVzLcRnbvZ2LcZXUYpVd1kmYr50MZV3YyI2cKJDT29GRjBjUIF2LcRHelR3LcJzLctmch1mclRXY39DOyIDOwMDM0EzMwETM2EDMy8CX0Vmbu4GZzNmLn9Gbi1yZtl2Lc9CX6MHc0RHaiojIsJye.jpg)
总结:这个程序虽然简单,但实实在在的解决了一种应用问题,这就是新技术带来的价值。新技术
在关键时刻总能发挥特殊的作用,就看你遇到没遇到这种关键的时刻,一旦遇到,那就能产生很大价值了。
转载请注明出处:http://blog.csdn.net/acmman/article/details/53020941