Exchanger可以在兩個線程之間交換數(shù)據(jù)，只能是2個線程，他不支持更多的線程之間互換數(shù)據(jù)。今天我們就通過實例來學(xué)習(xí)一下Exchanger的用法。

?

Exchanger的簡單實例

　　Exchanger是在兩個任務(wù)之間交換對象的柵欄，當(dāng)這些任務(wù)進入柵欄時，它們各自擁有一個對象。當(dāng)他們離開時，它們都擁有之前由對象持有的對象。它典型的應(yīng)用場景是：一個任務(wù)在創(chuàng)建對象，這些對象的生產(chǎn)代價很高昂，而另一個任務(wù)在消費這些對象。通過這種方式，可以有更多的對象在被創(chuàng)建的同時被消費。

一、Exchanger的簡單使用

package com.linux.huhx.concurreny;import java.util.concurrent.Exchanger; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors;public class ExchangerTest {public static void main(String[] args) {ExecutorService executor = Executors.newCachedThreadPool();final Exchanger exchanger = new Exchanger();executor.execute(new Runnable() {String data1 = "Ling";@Overridepublic void run() {doExchangeWork(data1, exchanger);}});executor.execute(new Runnable() {String data1 = "huhx";@Overridepublic void run() {doExchangeWork(data1, exchanger);}});executor.shutdown();}private static void doExchangeWork(String data1, Exchanger exchanger) {try {System.out.println(Thread.currentThread().getName() + "正在把數(shù)據(jù) " + data1 + " 交換出去");Thread.sleep((long) (Math.random() * 1000));String data2 = (String) exchanger.exchange(data1);System.out.println(Thread.currentThread().getName() + "交換數(shù)據(jù) 到 " + data2);} catch (InterruptedException e) {e.printStackTrace();}} }

運行結(jié)果如下：不固定

pool-1-thread-1正在把數(shù)據(jù) Ling 交換出去 pool-1-thread-2正在把數(shù)據(jù) huhx 交換出去 pool-1-thread-2交換數(shù)據(jù) 到 Ling pool-1-thread-1交換數(shù)據(jù) 到 huhx

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

轉(zhuǎn)載于:https://www.cnblogs.com/pypua/articles/8568425.html

總結(jié)

以上是生活随笔為你收集整理的java线程并发库之--线程同步工具Exchanger的使用的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

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