2019獨角獸企業(yè)重金招聘Python工程師標準>>>

Exchanger可以在兩個線程之間交換數(shù)據(jù)，只能是2個線程，他不支持更多的線程之間互換數(shù)據(jù)。

當線程A調用Exchange對象的exchange()方法后，他會陷入阻塞狀態(tài)，直到線程B也調用了exchange()方法，然后以線程安全的方式交換數(shù)據(jù)，之后線程A和B繼續(xù)運行。

今天決定花幾分鐘時間寫個小例子看下效果。以下實例演示了使用Exchange交換String數(shù)據(jù)，實際Exchange還可以交換對對象，比如交換List，HashMap，自定義的Model等。

源碼如下：

package demo19;import java.util.concurrent.Exchanger; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; /*** 使用Exchanger模擬買北京老冰棍的場景* @author mengfeiyang**/ public class ExchangeTest {public static void main(String[] args) {ExecutorService service = Executors.newCachedThreadPool();Exchanger<String> changer = new Exchanger<String>();service.submit(new Runnable(){public void run(){try{String data1 = "北京老冰棍";System.out.println("線程 "+Thread.currentThread().getName()+" 正在把 "+data1+" 拿出來");String data2 = changer.exchange(data1);System.out.println("線程 "+Thread.currentThread().getName()+"用 "+data1+" 換來了"+data2);}catch(Exception e){e.printStackTrace();}finally{service.shutdown();System.out.println(Thread.currentThread().getName()+"交易完畢，撤！");}}});service.submit(new Runnable(){public void run(){try{String data1 = "100元";System.out.println("線程 "+Thread.currentThread().getName()+" 正在把錢 "+data1+" 拿出來");String data2 = changer.exchange(data1);System.out.println("線程 "+Thread.currentThread().getName()+"用 "+data1+"換來了"+data2);}catch(Exception e){e.printStackTrace();}finally{service.shutdown();System.out.println(Thread.currentThread().getName()+"交易完畢，撤！");}}});} }

執(zhí)行結果：

轉載于:https://my.oschina.net/u/2391658/blog/710451

總結

以上是生活随笔為你收集整理的Java 线程数据交换控制器Exchange使用实例的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內容還不錯，歡迎將生活随笔推薦給好友。