Exchanger关于互换情报的例子

package com.test;import java.util.Random;import java.util.concurrent.Exchanger;import java.util.concurrent.ExecutorService;import java.util.concurrent.Executors;public class ExchangerTest{	/**	 * @param args	 */	public static void main(String[] args)	{		ExecutorService pool = Executors.newCachedThreadPool();		final Exchanger changer = new Exchanger();		pool.execute(new Runnable()		{			public void run()			{				String data1 = "情报1";				System.out.println("线程:" + Thread.currentThread().getName()						+ "准备把：" + data1+"交换出去");				try				{					Thread.sleep(new Random().nextInt(10000));					String data2 = (String)changer.exchange(data1);					System.out.println("线程:" + Thread.currentThread().getName()							+ "获得了：" + data2);				}				catch (Exception e)				{					e.printStackTrace();				}			}		});				pool.execute(new Runnable()		{			public void run()			{				String data1 = "情报2";				System.out.println("线程:" + Thread.currentThread().getName()						+ "准备把：" + data1+"交换出去");				try				{					Thread.sleep(new Random().nextInt(10000));					String data2 = (String)changer.exchange(data1);					System.out.println("线程:" + Thread.currentThread().getName()							+ "获得了：" + data2);				}				catch (Exception e)				{					e.printStackTrace();				}			}		});				pool.shutdown();	}}