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已經交換了數據。