Exchanger两个线程间数据交换
Exchanger用于进行线程间的数据交换,它提供一个同步点,在这个同步点,两个线
程可以交换彼此的数据;
两个线程通过exchange方法交换数据,如果一个线程先执行exchange方法,它会一直
等待第二个线程也执行exchange方法
当两个线程都达到同步点时,这两个线程就可以交换数据,将本线程生产出来的数据传
递给对方
使用场景:
两人录入excle比较数据是否一样
遗传算法:遗传算法里需要选出两个人作为交换对象,这时会交换两人的数据,并使
用交叉规则得出两个人交换结果。
用于校对工作:A、B同时录入数据,然后对A、B进行比较,看是否录入一致,保证数
据正确性。
比如我们需要将纸制银流通过人工的方式录入成电子银行流水,为了避免错误,采用
AB岗两人进行录入,录入到Excel之后,系统需要加载这两个Excel,并对这两个Excel
数据进行校对,看看是否录入的一致。
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();