1. 程式人生 > >java執行緒中Exchanger使用

java執行緒中Exchanger使用

有時我們需要對元素進行配對和交換執行緒的同步點,使用exchange方法 返回其夥伴的物件,這時我們就需要使用執行緒類中的Exchanger類了,

我通過一個例項 來簡單說明一下他的使用方法及其作用:

import java.util.concurrent.Exchanger;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;


public class TestExchanger {

	/**
	 * @param args
	 */
	public static void main(String[] args) {
         ExecutorService executor = Executors.newCachedThreadPool();
         final Exchanger<String> exchanger = new Exchanger<String>();
         executor.execute(new Runnable() {
			String data1 = "abc";
 			@Override
			public void run() {
				try {
					System.out.println(Thread.currentThread().getName() +"正在把資料 "+ data1+ " 交換出去" );
					Thread.sleep((long) (Math.random()*1000));
					
					String data2 = (String) exchanger.exchange(data1);
					System.out.println(Thread.currentThread().getName() + "交換資料 到  "+ data2);
				} catch (InterruptedException e) {
					e.printStackTrace();
				}
			}
		});
         
         executor.execute(new Runnable() {
        	 String data1 = "def";
			@Override
			public void run() {
				try {
					System.out.println(Thread.currentThread().getName() +"正在把資料 "+ data1+ " 交換出去" );
					Thread.sleep((long) (Math.random()*1000));
					
					String data2 = (String) exchanger.exchange(data1);
					System.out.println(Thread.currentThread().getName() + "交換資料 到  "+ data2);
				} catch (InterruptedException e) {
					e.printStackTrace();
				}
			}
		});
	}

}

執行完畢之後;你會發現資料完成交換

pool-1-thread-1正在把資料 abc 交換出去
pool-1-thread-2正在把資料 def 交換出去
pool-1-thread-2交換資料 到  abc
pool-1-thread-1交換資料 到  def