簡介

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

Exchanger的應用場景

Exchanger可以用於遺傳演算法，遺傳演算法裡需要選出兩個人作為交配物件，這時候會交換兩人的資料，並使用交叉規則得出2個交配結果。
Exchanger也可以用於校對工作。比如我們需要將紙製銀流通過人工的方式錄入成電子銀行流水，為了避免錯誤，採用AB崗兩人進行錄入，錄入到Excel之後，系統需要載入這兩個Excel，並對這兩個Excel資料進行校對，看看是否錄入的一致。程式碼如下：

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() {
			@Override
			public void run() {
				try {
					String A = "銀行流水A";// A錄入銀行流水資料
					exgr.exchange(A);
				} catch (InterruptedException e) {
				}
			}
		});

		threadPool.execute(new Runnable() {
			@Override
			public 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) {
				}
			}
		});

		threadPool.shutdown();

	}
}

其他方法

如果兩個執行緒有一個沒有到達exchange方法，則會一直等待,如果擔心有特殊情況發生，避免一直等待，可以使用exchange(V x, long timeout, TimeUnit unit)設定最大等待時長。

方 騰飛

花名清英，併發網(ifeve.com)創始人，暢銷書《Java併發程式設計的藝術》作者，螞蟻金服技術專家。目前工作於支付寶微貸事業部，關注網際網路金融，併發程式設計和敏捷實踐。微信公眾號aliqinying。