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();

    }

}