首页 > 代码库 > Java--Exchanger用于进行线程间的数据交换

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

 

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