前言

??JDK中為了處理線程之間的同步問題，除了提供鎖機制之外，還提供了幾個非常有用的并發(fā)工具類：CountDownLatch、CyclicBarrier、Semphore、Exchanger、Phaser；
??CountDownLatch、CyclicBarrier、Semphore、Phaser 這四個工具類提供一種并發(fā)流程的控制手段；而Exchanger工具類則提供了在線程之間交換數(shù)據(jù)的一種手段。

簡介

?? Exchanger的功能是使2個線程之間交換數(shù)據(jù)（有不少文章的說法是“傳輸數(shù)據(jù)”，應該叫“交換數(shù)據(jù)”更合適，因為這是兩個線程都要向對方傳送數(shù)據(jù)，同時也獲取對方的傳送過來的數(shù)據(jù)，是

雙向模式，并不是一個線程向另一個線程傳輸數(shù)據(jù)）。它比生產(chǎn)者/消費者模式使用的wait/notify要更加方便。
??Exchanger 提供一個同步點，在這個同步點處，兩個線程可以交換彼此數(shù)據(jù)。即一個線程調(diào)用了exchange( )方法交換數(shù)據(jù)，到達了同步點，然后就會一直阻塞等待另一個線程調(diào)用exchange( )方法來交換數(shù)據(jù)。所以，要注意exchange( )方法是有阻塞的特性。
Exchanger 可能在應用程序（比如遺傳算法和管道設計）中很有用。

方法摘要

public V exchange(V x) throws InterruptedException
等待另一個線程到達此交換點（除非當前線程被中斷），然后將給定的對象傳送給該線程，并接收該線程的對象。
public V exchange(V x, long timeout, TimeUnit unit) throws InterruptedException, TimeoutException
等待另一個線程到達此交換點（除非當前線程被中斷，或者超出了指定的等待時間），然后將給定的對象傳送給該線程，同時接收該線程的對

@ Example1?用法示例

以下是重點介紹的一個類，該類使用 Exchanger 在線程間交換緩沖區(qū)，因此，在需要時，填充緩沖區(qū)的線程獲取一個新騰空的緩沖區(qū)，并將填滿的緩沖區(qū)傳遞給騰空緩沖區(qū)的線程

class FillAndEmpty {Exchanger<DataBuffer> exchanger = new Exchanger<DataBuffer>();DataBuffer initialEmptyBuffer = ... a made-up typeDataBuffer initialFullBuffer = ...class FillingLoop implements Runnable {public void run() {DataBuffer currentBuffer = initialEmptyBuffer;try {while (currentBuffer != null) {addToBuffer(currentBuffer);if (currentBuffer.isFull())currentBuffer = exchanger.exchange(currentBuffer);}} catch (InterruptedException ex) { ... handle ... }}}class EmptyingLoop implements Runnable {public void run() {DataBuffer currentBuffer = initialFullBuffer;try {while (currentBuffer != null) {takeFromBuffer(currentBuffer);if (currentBuffer.isEmpty())currentBuffer = exchanger.exchange(currentBuffer);}} catch (InterruptedException ex) { ... handle ...}}}void start() {new Thread(new FillingLoop()).start();new Thread(new EmptyingLoop()).start();}} 復制代碼

@ Example2?應用場景示例

Exchanger可以用于

遺傳算法，遺傳算法里需要選出兩個人作為交配對象，這時候會交換兩人的數(shù)據(jù)，并使用交叉規(guī)則得出2個交配結果。

Exchanger也可以用于

校對工作。

比如我們需要將紙制銀流通過人工的方式錄入成電子銀行流水，為了避免錯誤，采用AB崗兩人進行錄入，錄入到Excel之后，系統(tǒng)需要加載這兩個Excel，并對這兩個Excel數(shù)據(jù)進行校對，看看是否錄入的一致。代碼如下：

private static final Exchanger<String> exgr = new Exchanger<String>(); private static ExecutorService threadPool = Executors.newFixedThreadPool(2);public static void main(String[] args) {threadPool.execute(new Runnable() {@Overridepublic void run() {try {String A = "銀行流水A";// A錄入銀行流水數(shù)據(jù)exgr.exchange(A);//同步點，交換數(shù)據(jù)} catch (InterruptedException e) {}}});threadPool.execute(new Runnable() {@Overridepublic void run() {try {String B = "銀行流水B";// B錄入銀行流水數(shù)據(jù)String A = exgr.exchange("B");//同步點，交換數(shù)據(jù)System.out.println("A和B數(shù)據(jù)是否一致：" + A.equals(B) + "\nA錄入的是："+ A + "\nB錄入的是：" + B);} catch (InterruptedException e) {}}});threadPool.shutdown(); } 復制代碼

運行結果：

A和B數(shù)據(jù)是否一致：false A錄入的是：銀行流水A B錄入的是：銀行流水B 復制代碼

文章源地址：https://www.cnblogs.com/jinggod/p/8494384.html

總結

以上是生活随笔為你收集整理的并发工具类（四）线程间的交换数据 Exchanger的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

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