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

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

import java.util.concurrent.Exchanger;import java.util.concurrent.ExecutorService;import java.util.concurrent.Executors;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錄入銀行流水數(shù)據(jù)String B = exgr.exchange(A);System.out.println("A:得到的線程："+B);} catch (InterruptedException e) {}}});threadPool.execute(new Runnable() {@Overridepublic void run() {try {String B = "銀行流水B";// B錄入銀行流水數(shù)據(jù)String A = exgr.exchange(B);System.out.println("B:得到的線程："+A);} catch (InterruptedException e) {}}});threadPool.shutdown();}}

如果兩個線程有一個沒有執(zhí)行exchange()方法，則會一直等待，如果擔心有特殊情況發(fā)生，避免一直等待，可以使用exchange（V x，longtimeout，TimeUnit unit）設置最大等待時長。