并发库应用之十 & 多线程数据交换Exchanger应用
申明：用大白话来说就是用于实现两个人之间的数据交换，每个人在完成一定的事务后想与对方交换数据，第一个先拿出数据的人会一直等待第二个人，直到第二个人拿着数据到来时，才能彼此交换数据。java.util.concurrent.Exchanger<V> V 表示可以交换的对象类型
对应构造方法摘要：
Exchanger() 创建一个新的 Exchanger
方法摘要：
Vexchange(V v) 等待另一个线程到达此交换点(除非当前线程被中断)，然后将给定的对象传送给该线程，并接收该线程的对象
Vexchange(V v, long timeout, TimeUnit unit)
等待另一个线程到达此交换点（除非当前线程被中断，或者超出了指定的等待时间），然后将给定的对象传送给该线程，同时接收该线程的对象
案例应用：
好比两个毒贩要进行交易，一手交钱、一手交货，不管谁先来到接头地点后，就处于等待状态了，当另外一方也到达了接头地点（所谓到达接头地点，也就是到到达了准备接头的状态）时，两者的数据就立即交换了，然后就又可以各忙各的了。我们用代码来实现这个例子：
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 {
Thread.sleep((long) (Math.random() * 5000));
String ownData = "毒品货物";
System.out.println(String.format("线程毒贩 %s 准备把数据【%s】换出去", Thread.currentThread().getName(), ownData));
String receiveData = (String) exchanger.exchange(ownData);
System.out.println(String.format("线程毒贩 %s 换回的数据是【%s】", Thread.currentThread().getName(), receiveData));
} catch (Exception e) {}
}
});
service.execute(new Runnable() {
public void run() {
try {
Thread.sleep((long) (Math.random() * 5000));
String ownData = "毛爷爷纸币";
System.out.println(String.format("线程吸毒者 %s 准备把数据【%s】换出去", Thread.currentThread().getName(), ownData));
String receiveData = (String) exchanger.exchange(ownData);
System.out.println(String.format("线程吸毒者 %s 换回的数据是【%s】", Thread.currentThread().getName(), receiveData));
} catch (Exception e) {}
}
});
}
}
以上代码运行结果打印效果如下：
提示：欢迎继续参看我相关的下一篇博客：并发库应用之十一 & 阻塞队列的应用
页:
[1]