Java 并发编程（十五）：并发工具 Exchanger

谁践踏了优雅 2022-03-22 09:19 344阅读 0赞

## 1、概述 ##

Exchanger（交换器）是一个用于线程间协作的工具类。Exchanger用于进行线程间的数据交换。它提供一个同步点，在这个同步点两个线程可以交换彼此的数据。

这两个线程通过exchange方法交换数据， 如果第一个线程先执行exchange方法，它会一直等待第二个线程也执行exchange，当两个线程都到达同步点时，这两个线程就可以交换数据，将本线程生产出来的数据传递给对方

## 2、类图 ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTA2NDcwMzU_size_16_color_FFFFFF_t_70]

如果两个线程有一个没有到达exchange方法，则会一直等待,如果担心有特殊情况发生，避免一直等待，可以设置最大等待时长。

public V exchange(V x, long timeout, TimeUnit unit)

## 3、适用场景 ##

Exchanger可以用于遗传算法，遗传算法里需要选出两个人作为交换对象，这时候会交换两人的数据，并使用交叉规则得出2个交换结果。

Exchanger也可以用于校对工作。比如我们需要将纸制银流通过人工的方式录入成电子银行流水，为了避免错误，采用AB岗两人进行录入，录入到Excel之后，系统需要加载这两个Excel，并对这两个Excel数据进行校对，看看是否录入的一致

## 4、代码示例 ##

public class ExchangerTest {
        //交换器
        private static final Exchanger<String> exgr = new Exchanger<String>();
    
        //线程池
        private static ExecutorService threadPool = newFixedThreadPool(2);
    
        public static void main(String[] args) {
    
            threadPool.execute(() -> {
                try {
                    String threadAData = "线程A的数据";
                    exgr.exchange(threadAData);
                } catch (InterruptedException e) {
                }
            });
    
            threadPool.execute(() -> {
                try {
                    String threadBData = "线程B的数据";
                    String threadAData = exgr.exchange("B");
                    System.out.println("A和B数据是否一致：" + threadAData.equals(threadBData) + ",A录入的是："
                            + threadAData + ",B录入是：" + threadBData);
                } catch (InterruptedException e) {
                }
            });
    
            threadPool.shutdown();
    
        }
    }

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTA2NDcwMzU_size_16_color_FFFFFF_t_70]: /images/20220322/d8f614047f4f46b0a76b942352bcd311.png