线程安全——J.U.C工具类——Exchanger两个线程间数据交换，比如应用在数据比对

Exchanger两个线程间数据交换

Exchanger用于进行线程间的数据交换&＃xff0c;它提供一个同步点&＃xff0c;在这个同步点&＃xff0c;两个线
程可以交换彼此的数据&＃xff1b;
两个线程通过exchange方法交换数据&＃xff0c;如果一个线程先执行exchange方法&＃xff0c;它会一直
等待第二个线程也执行exchange方法
当两个线程都达到同步点时&＃xff0c;这两个线程就可以交换数据&＃xff0c;将本线程生产出来的数据传
递给对方


使用场景&＃xff1a;

两人录入excle比较数据是否一样

遗传算法&＃xff1a;遗传算法里需要选出两个人作为交换对象&＃xff0c;这时会交换两人的数据&＃xff0c;并使
用交叉规则得出两个人交换结果。
用于校对工作&＃xff1a;A、B同时录入数据&＃xff0c;然后对A、B进行比较&＃xff0c;看是否录入一致&＃xff0c;保证数
据正确性。
比如我们需要将纸制银流通过人工的方式录入成电子银行流水&＃xff0c;为了避免错误&＃xff0c;采用
AB岗两人进行录入&＃xff0c;录入到Excel之后&＃xff0c;系统需要加载这两个Excel&＃xff0c;并对这两个Excel
数据进行校对&＃xff0c;看看是否录入的一致。

Exchanger exchanger &＃61; new Exchanger<>();//需要交换的数据


ExecutorService executorService &＃61; Executors.newFixedThreadPool(2);//定义两个线程

package com.bfxy.thread.core.juc;import java.util.concurrent.Exchanger;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;public class UseExchanger {private static final Exchanger exchanger &＃61; new Exchanger<>();private static ExecutorService executorService &＃61; Executors.newFixedThreadPool(2);public static void main(String[] args) {executorService.execute(new Runnable() {&＃64;Overridepublic void run() {String A &＃61; "银行流水A";try {String B &＃61; exchanger.exchange(A); //交换我自己的数据 并且获取别人的数据System.err.println("线程A: " &＃43; B);} catch (InterruptedException e) {e.printStackTrace();} }});executorService.execute(new Runnable() {&＃64;Overridepublic void run() {String B &＃61; "银行流水B";try {String A &＃61; exchanger.exchange(B); //交换我自己的数据 并且获取别人的数据System.err.println("线程B: " &＃43; A);} catch (InterruptedException e) {e.printStackTrace();} }});executorService.shutdown();}}


注意&＃xff1a;只能用在两个线程交换数据&＃xff0c;关闭线程池//executorService.shutdown();