java執行緒中Exchanger使用
阿新 • • 發佈:2019-01-24
有時我們需要對元素進行配對和交換執行緒的同步點,使用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