java線程中Exchanger使用
來源：程序員人生 發布時間：2014-11-13 08:49:22 閱讀次數：2691次
有時我們需要對元素進行配對和交換線程的同步點，使用exchange方法 返回其火伴的對象，這時候我們就需要使用線程類中的Exchanger類了，
我通過1個實例 來簡單說明1下他的使用方法及其作用：
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⑴-thread⑴正在把數據 abc 交換出去
pool⑴-thread⑵正在把數據 def 交換出去
pool⑴-thread⑵交換數據 到 abc
pool⑴-thread⑴交換數據 到 def
生活不易，碼農辛苦
如果您覺得本網站對您的學習有所幫助,可以手機掃描二維碼進行捐贈
