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() {
@Override
public 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() {
@Override
public 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
*/