public class ExchangerTest {
	public static void main(String[] args) {
		ExecutorService service = Executors.newCachedThreadPool();
		final Exchanger exchanger = new Exchanger();
		//定義一個(gè)交換對象，用來交換數(shù)據(jù)
		//開啟一個(gè)線程執(zhí)行任務(wù)
		service.execute(new Runnable(){
			@Override
			      public void run() {
				try {
					String data1 = "海洛因";
					System.out.println("線程" + Thread.currentThread().getName() 
					              + "正在把毒品" + data1 + "拿出來");
					Thread.sleep((long)(Math.random()*10000));
					//把要交換的數(shù)據(jù)傳到exchange方法中，然后被阻塞，等待另一個(gè)線程與之交換。返回交換后的數(shù)據(jù)
					String data2 = (String)exchanger.exchange(data1);
					System.out.println("線程" + Thread.currentThread().getName() + 
					          "用海洛因換來了" + data2);
				}
				catch(Exception e){
				}
				finally {
					service.shutdown();
					System.out.println("交易完畢，拿著錢快跑！");
				}
			}
		}
		);
		//開啟另一個(gè)線程執(zhí)行任務(wù)
		service.execute(new Runnable(){
			@Override
			      public void run() {
				try {
					String data1 = "300萬";
					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() + 
					          "用300萬弄到了" + data2);
				}
				catch(Exception e){
				}
				finally {
					service.shutdown();
					System.out.println("交易完畢，拿著海洛因快跑！");
				}
			}
		}
		);
	}
}