并发库应用之十 & 多线程数据交换Exchanger应用

Posted 星火燎原智勇

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了并发库应用之十 & 多线程数据交换Exchanger应用相关的知识,希望对你有一定的参考价值。

  申明:用大白话来说就是用于实现两个人之间的数据交换,每个人在完成一定的事务后想与对方交换数据,第一个先拿出数据的人会一直等待第二个人,直到第二个人拿着数据到来时,才能彼此交换数据。

  java.util.concurrent.Exchanger<V>     V 表示可以交换的对象类型

对应构造方法摘要:

  Exchanger()           创建一个新的 Exchanger

方法摘要:

  V  exchange(V v)            等待另一个线程到达此交换点(除非当前线程被中断),然后将给定的对象传送给该线程,并接收该线程的对象

  V  exchange(V v, long timeout, TimeUnit unit)

   等待另一个线程到达此交换点(除非当前线程被中断,或者超出了指定的等待时间),然后将给定的对象传送给该线程,同时接收该线程的对象

案例应用:

  好比两个毒贩要进行交易,一手交钱、一手交货,不管谁先来到接头地点后,就处于等待状态了,当另外一方也到达了接头地点(所谓到达接头地点,也就是到到达了准备接头的状态)时,两者的数据就立即交换了,然后就又可以各忙各的了。我们用代码来实现这个例子:

 1 import java.util.concurrent.Exchanger;
 2 import java.util.concurrent.ExecutorService;
 3 import java.util.concurrent.Executors;
 4 
 5 public class ExchangerTest {
 6 
 7     public static void main(String[] args) {
 8         ExecutorService service = Executors.newCachedThreadPool();
 9         final Exchanger exchanger = new Exchanger();
10         service.execute(new Runnable() {
11             public void run() {
12                 try {
13                     Thread.sleep((long) (Math.random() * 5000));
14                     String ownData = "毒品货物";
15                     System.out.println(String.format("线程毒贩 %s 准备把数据【%s】换出去", Thread.currentThread().getName(), ownData));
16                     String receiveData = (String) exchanger.exchange(ownData);
17                     System.out.println(String.format("线程毒贩 %s 换回的数据是【%s】", Thread.currentThread().getName(), receiveData));
18                 } catch (Exception e) {}
19             }
20         });
21 
22         service.execute(new Runnable() {
23             public void run() {
24                 try {
25                     Thread.sleep((long) (Math.random() * 5000));
26                     String ownData = "毛爷爷纸币";
27                     System.out.println(String.format("线程吸毒者 %s 准备把数据【%s】换出去", Thread.currentThread().getName(), ownData));
28                     String receiveData = (String) exchanger.exchange(ownData);
29                     System.out.println(String.format("线程吸毒者 %s 换回的数据是【%s】", Thread.currentThread().getName(), receiveData));
30                 } catch (Exception e) {}
31             }
32         });
33     }
34 }

以上代码运行结果打印效果如下:

  

 提示:欢迎继续参看我相关的下一篇博客:并发库应用之十一 & 阻塞队列的应用

以上是关于并发库应用之十 & 多线程数据交换Exchanger应用的主要内容,如果未能解决你的问题,请参考以下文章

Java 并发系列之十三:安全发布

多线程并发库

Java多线程与并发库高级应用-java5线程并发库

并发库应用之四 & 线程锁Lock应用

Java多线程与并发库高级应用-线程池

Java多线程与并发库高级应用-传统线程互斥技术