Java--Exchanger用于进行线程间的数据交换

期盼死亡的小丑

package com;
import java.util.concurrent.Exchanger;
/**
* Created by yangyu on 16/11/28.
*/
/**
* Exchanger用于进行线程间的数据交换；
* 它提供一个同步点，在这个同步点，两个线程可以交换彼此的数据；
* 两个线程通过exchange方法交换数据，如果一个线程先执行exchange方法，它会一直等待第二个线程也执行exchange方法
* 当两个线程都达到同步点时，这两个线程就可以交换数据，将本线程生产出来的数据传递给对方
*
* Exchanger使用场景：
* 1.遗传算法：遗传算法里需要选出两个人作为交配对象，这时会交换两人的数据，并使用交叉规则得出两个人交配结果。
* 2.用于校对工作：A、B同时录入数据，然后对A、B进行比较，看是否录入一致，保证数据正确性。
*/
public class TestExchanger {
private static Exchanger<String> exchanger = new Exchanger<>();
public static void main(String[] args) {
new Thread(()->{
String A = "yangyu";
try {
String B = exchanger.exchange(A);
System.out.println("this is A,but B is:"+B);
} catch (InterruptedException e) {
e.printStackTrace();
}
}).start();
new Thread(()->{
String B = "java code";
try {
String A = exchanger.exchange(B);
System.out.println("this is B,but A is:"+A);
} catch (InterruptedException e) {
e.printStackTrace();
}
}).start();
}
}