并发工具类(四)两个线程进行数据交换的Exchanger-阿里云开发者社区

开发者社区> 青衫无名> 正文

并发工具类(四)两个线程进行数据交换的Exchanger

简介:
+关注继续查看

简介

Exchanger(交换者)是一个用于线程间协作的工具类。Exchanger用于进行线程间的数据交换。它提供一个同步点,在这个同步点两个线程可以交换彼此的数据。这两个线程通过exchange方法交换数据, 如果第一个线程先执行exchange方法,它会一直等待第二个线程也执行exchange,当两个线程都到达同步点时,这两个线程就可以交换数据,将本线程生产出来的数据传递给对方。

Exchanger的应用场景

Exchanger可以用于遗传算法,遗传算法里需要选出两个人作为交配对象,这时候会交换两人的数据,并使用交叉规则得出2个交配结果。
Exchanger也可以用于校对工作。比如我们需要将纸制银流通过人工的方式录入成电子银行流水,为了避免错误,采用AB岗两人进行录入,录入到Excel之后,系统需要加载这两个Excel,并对这两个Excel数据进行校对,看看是否录入的一致。代码如下:

01 public class ExchangerTest {
02  
03     private static final Exchanger<String> exgr = new Exchanger<String>();
04  
05     private static ExecutorService threadPool = Executors.newFixedThreadPool(2);
06  
07     public static void main(String[] args) {
08  
09         threadPool.execute(new Runnable() {
10             @Override
11             public void run() {
12                 try {
13                     String A = "银行流水A";// A录入银行流水数据
14                     exgr.exchange(A);
15                 catch (InterruptedException e) {
16                 }
17             }
18         });
19  
20         threadPool.execute(new Runnable() {
21             @Override
22             public void run() {
23                 try {
24                     String B = "银行流水B";// B录入银行流水数据
25                     String A = exgr.exchange("B");
26                     System.out.println("A和B数据是否一致:" + A.equals(B) + ",A录入的是:"
27                             + A + ",B录入是:" + B);
28                 catch (InterruptedException e) {
29                 }
30             }
31         });
32  
33         threadPool.shutdown();
34  
35     }
36 }

其他方法

如果两个线程有一个没有到达exchange方法,则会一直等待,如果担心有特殊情况发生,避免一直等待,可以使用exchange(V x, long timeout, TimeUnit unit)设置最大等待时长。

版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。

相关文章
我珍藏的神兵利器 - 效率工具for Win[转]
    工欲善其事必先利其器。 我一直都在不断挑选和优化自己的兵器,以追求着最高效率。 此篇分享下我的私家珍藏的各种神兵利器。如果有朋友能推荐更好的,那就不枉此篇。
2875 0
并发服务器三种实现方式之进程、线程和select
这篇主要介绍如何实现并发服务器,主要通过三种方式:进程、线程和select函数来分别实现。
1419 0
Java 使用轮询获取线程返回数据
本文目录 1. 多线程的特点 2. 使用轮询强制等待 3. 轮询的弊端 4. 小结
9 0
Java进阶之并发编程——《我的Java打怪日记》
Java进阶之并发编程——《我的Java打怪日记》
37061 0
+关注
3598
文章
840
问答
文章排行榜
最热
最新
相关电子书
更多
《2021云上架构与运维峰会演讲合集》
立即下载
《零基础CSS入门教程》
立即下载
《零基础HTML入门教程》
立即下载