Exchanger
- Exchanger用于进行线程间的数据交换,它提供一个同步点,在这个同步点,两个线程可以交换彼此的数据
- 两个线程通过exchange方法交换数据,如果一个线程先执行exchange方法,它会一直等待第二个线程也执行exchange方法
- 当两个线程都达到同步点时,这两个线程就可以交换数据,将本线程生产出来的数据传递给对方(只能在两个线程之间交换数据)
使用场景
- 遗传算法:遗传算法里需要选出两个人作为交换对象,这时会交换两人的数据,并使用交叉规则得出两个人交换结果。
- 校对工作:A、B同时录入数据,然后对A、B进行比较,看是否录入一致,保证数据正确性
package com.example.core.juc;import org.springframework.jmx.export.naming.IdentityNamingStrategy;import java.util.concurrent.Exchanger;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;public class UseExchanger {private static final Exchanger<String> exchanger = new Exchanger<>();//Exchanger<String>交换String类型//Exchanger用于两个数据之间的数据交换private static ExecutorService executorService = Executors.newFixedThreadPool(2);public static void main(String[] args) {executorService.execute(new Runnable() {@Overridepublic void run() {String A = "银行流水A";try{String B = exchanger.exchange(A);//交换我自己的数据,并且获取别人的数据System.out.println("线程A:"+B);}catch (InterruptedException w){w.printStackTrace();}}});executorService.execute(new Runnable() {@Overridepublic void run() {String B = "银行流水B";try{String A = exchanger.exchange(B);//交换我自己的数据,并且获取别人的数据System.out.println("线程B:"+A);}catch (InterruptedException w){w.printStackTrace();}}});executorService.shutdown();//关闭线程池}
}
/*
output:
线程B:银行流水A
线程A:银行流水B*/