版权声明:本文为博主原创文章,未经博主允许不得转载。 https://blog.csdn.net/havebeenstand/article/details/83791723
1.概述
用于实现两个人之间的数据交换,每个人在完成一定的事务后想与对方交换数据,第一个先拿出数据的人将一直等待第二个人拿着数据到来时,才能彼此交换数据
2.代码示例
public class ExchangerStudy {
public static void main(String[] args) {
ExecutorService es = Executors.newCachedThreadPool();
Exchanger<String> changer = new Exchanger<String>();
es.execute(new Runnable() {
@Override
public void run() {
try {
String data1 = "线程1的数据";
System.out.println("线程"+Thread.currentThread().getName()+"正在准备把线程1的数据换出去");
Thread.sleep((long)Math.random()*10000);
String data2 = changer.exchange(data1);
System.out.println("线程"+Thread.currentThread().getName()+"换回来的数据为:"+data2);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
});
es.execute(new Runnable() {
@Override
public void run() {
try {
String data1 = "线程2的数据";
System.out.println("线程"+Thread.currentThread().getName()+"正在准备把线程2的数据换出去");
Thread.sleep((long)Math.random()*10000);
String data2 = changer.exchange(data1);
System.out.println("线程"+Thread.currentThread().getName()+"换回来的数据为:"+data2);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
});
}
}
运行结果