concurrent包下的Exchanger练习

Exchanger可以在两个线程之间交换数据，只能是2个线程，他不支持更多的线程之间互换数据。

当线程A调用Exchange对象的exchange()方法后，他会陷入阻塞状态，直到线程B也调用了exchange()方法，然后以线程安全的方式交换数据，之后线程A和B继续运行。

package cn.sp.test4;

import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.Exchanger;

/**
 * Created by 2YSP on 2017/9/1.
 * 两个线程之间交换数据
 */
public class ExchangerTest {


    public static void main(String[] args) {
        final Exchanger<List<Integer>> exchanger = new Exchanger<>();

        new Thread(() -> {
            List<Integer> l = new ArrayList<Integer>(2);
            l.add(1);
            l.add(2);
            try {
                l = exchanger.exchange(l);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println("thread1: " + l);
        }).start();

        new Thread(() -> {
            List<Integer> l = new ArrayList<Integer>(2);
            l.add(3);
            l.add(4);
            try {
                l = exchanger.exchange(l);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println("thread2: " + l);
        }).start();

    }
}

执行结果：

可以看到线程1和2已经交换了数据。