并发包交换数据Exchanger

/**
 * 
 * @描述: 用于实现两我的之间的数据交换，每一个人完成必定的事务后想与对方交换数据，第一个先拿出数据的人一直等待
 * 直到第二我的拿到数据 到来时，才能彼此交换数据.
 * @做者: Wnj .
 * @建立时间: 2017年5月16日 .
 * @版本: 1.0 .
 */
public class ExchangerTest {
    
    public static void main(String[] args) {
        ExecutorService service = Executors.newCachedThreadPool();
        final Exchanger exchanger = new Exchanger();
        service.execute(new Runnable() {
            public void run() {
                try {
                    
                    String data1 = "zxx";
                    System.out.println("线程：" + Thread.currentThread().getName() + "正准备把数据" + data1 + "换过去");
                    Thread.sleep((long)(Math.random() * 10000));
                    String data2 = (String)exchanger.exchange(data1);
                    System.out.println("线程：" + Thread.currentThread().getName() + "换回数据" + data2);
                }
                catch (Exception e) {
                    
                }
            }
        });
        service.execute(new Runnable() {
            public void run() {
                try {
                    
                    String data1 = "lhm";
                    System.out.println("线程：" + Thread.currentThread().getName() + "正准备把数据" + data1 + "换过去");
                    Thread.sleep((long)(Math.random() * 10000));
                    String data2 = (String)exchanger.exchange(data1);
                    System.out.println("线程：" + Thread.currentThread().getName() + "换回数据" + data2);
                }
                catch (Exception e) {
                    
                }
            }
        });
    }
}