?

01 Exchanger 作用

使兩個線程之間進行數據傳遞。（對是兩個之間而不是三個或者更多個線程之間）

02 常用方法

exchange（）?阻塞當前線程并等待其他線程來取得數據，若沒有其他線程來取數據則一直等待。

exchange（）?傳遞數據

exchange(V v, long timeout, TimeUnit unit)?在指定的時間內沒收到消息，則拋出超時的異常。

Exchanger（交換者）是一個用于線程間協作的工具類。Exchanger用于進行線程間的數據交換。它提供一個同步點，在這個同步點兩個線程可以交換彼此的數據。這兩個線程通過exchange方法交換數據， 如果第一個線程先執行exchange方法，它會一直等待第二個線程也執行exchange，當兩個線程都到達同步點時，這兩個線程就可以交換數據，將本線程生產出來的數據傳遞給對方。

Exchanger的應用場景

Exchanger可以用于遺傳算法，遺傳算法里需要選出兩個人作為交配對象，這時候會交換兩人的數據，并使用交叉規則得出2個交配結果。
Exchanger也可以用于校對工作。比如我們需要將紙制銀流通過人工的方式錄入成電子銀行流水，為了避免錯誤，采用AB崗兩人進行錄入，錄入到Excel之后，系統需要加載這兩個Excel，并對這兩個Excel數據進行校對，看看是否錄入的一致。代碼如下：

import java.util.concurrent.Exchanger; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors;/*** TODO 在此寫上類的相關說明.<br>* @author gqltt <br>* @version 1.0.0 2021年11月29日<br>* @see * @since JDK 1.5.0*/ public class ExchangerTest {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錄入銀行流水數據exgr.exchange(A);} catch (InterruptedException e) {Thread.interrupted();}}});threadPool.execute(new Runnable() {@Overridepublic void run() {try {String B = "銀行流水B";// B錄入銀行流水數據String A = exgr.exchange(B);System.out.println("A和B數據是否一致：" + A.equals(B) + ",A錄入的是："+ A + ",B錄入是：" + B);} catch (InterruptedException e) {Thread.interrupted();}}});threadPool.shutdown();} }

總結

以上是生活随笔為你收集整理的Exchanger及其用法的全部內容，希望文章能夠幫你解決所遇到的問題。

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