2019獨(dú)角獸企業(yè)重金招聘Python工程師標(biāo)準(zhǔn)>>>

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

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

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

源碼如下：

package demo19;import java.util.concurrent.Exchanger; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; /*** 使用Exchanger模擬買北京老冰棍的場(chǎng)景* @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+" 拿出來(lái)");String data2 = changer.exchange(data1);System.out.println("線程 "+Thread.currentThread().getName()+"用 "+data1+" 換來(lái)了"+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+" 拿出來(lái)");String data2 = changer.exchange(data1);System.out.println("線程 "+Thread.currentThread().getName()+"用 "+data1+"換來(lái)了"+data2);}catch(Exception e){e.printStackTrace();}finally{service.shutdown();System.out.println(Thread.currentThread().getName()+"交易完畢，撤！");}}});} }

執(zhí)行結(jié)果：

轉(zhuǎn)載于:https://my.oschina.net/u/2391658/blog/710451

總結(jié)

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

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