Java多线程与并发库高级应用之线程数据交换Exchanger

JDK1.5提供了Exchanger用于两个线程的数据交换。两个线程先后到达交换点，先到达的线程会等待后到达的线程，然后两个线程互相交换数据，交换后双方持对方的数据。

Exchanger只提供了一个构造器：

Exchanger()：创建一个新的Exchanger。

Exchanger中也只有两个方法：

V exchange(V x)： 等待另一个线程到达此交换点（除非当前线程被中断），然后将给定的对象传送给该线程，并接收该线程的对象。

V exchange(V x, long timeout, TimeUnit unit)： 等待另一个线程到达此交换点（除非当前线程被中断，或者超出了指定的等待时间），然后将给定的对象传送给该线程，同时接收该线程的对象。

见下面程序

public class ExchangerDemo {

    public static void main(String[] args) {

        //线程池
        ExecutorService pool = Executors.newCachedThreadPool();
        //Exchanger
        final Exchanger<String> changer = new Exchanger<String>();

        //用于交互数据的线程1
        pool.execute(new Runnable() {

            @Override
            public void run() {
                try{
                    String data1 = "苹果";
                    System.out.println(Thread.currentThread().getName() +
                            "-准备交换数据：" + data1);
                    Thread.sleep((long)(Math.random()*10000));
                    String data2 = (String)changer.exchange(data1);
                    System.out.println(Thread.currentThread().getName() +
                            "-已交换完数据，交换到的数据：" + data1);
                }catch(InterruptedException e){
                    e.printStackTrace();
                }
            }
        });

        //用于交互数据的线程2
        pool.execute(new Runnable() {

            @Override
            public void run() {
                try{
                    String data1 = "石榴";
                    System.out.println(Thread.currentThread().getName() +
                            "-准备交换数据：" + data1);
                    Thread.sleep((long)(Math.random()*10000));
                    String data2 = (String)changer.exchange(data1);
                    System.out.println(Thread.currentThread().getName() +
                            "-已交换完数据，交换到的数据：" + data1);
                }catch(InterruptedException e){
                    e.printStackTrace();
                }
            }
        });

        pool.shutdown();
    }
}

运行程序

看到两个线程将数据彼此交换。