寫在前面

　　前面三篇博客分別介紹了CyclicBarrier、CountDownLatch、Semaphore，現在介紹并發工具類中的最后一個Exchange。Exchange是最簡單的也是最復雜的，簡單在于API非常簡單，就一個構造方法和兩個exchange()方法，最復雜在于它的實現是最復雜的（本文不解釋。太復雜）

　　在API是這么介紹的：可以在對中對元素進行配對和交換的線程的同步點。每個線程將條目上的某個方法呈現給 exchange 方法，與伙伴線程進行匹配，并且在返回時接收其伙伴的對象。Exchanger 可能被視為 SynchronousQueue 的雙向形式。Exchanger 可能在應用程序（比如遺傳算法和管道設計）中很有用。

　　Exchanger，它允許在并發任務之間交換數據。具體來說，Exchanger類允許在兩個線程之間定義同步點。當兩個線程都到達同步點時，他們交換數據結構，因此第一個線程的數據結構進入到第二個線程中，第二個線程的數據結構進入到第一個線程中。

?

應用示例

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) {}}});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) {}}});threadPool.shutdown();} }

示例2

public class ExchangerTest {static class Producer implements Runnable{//生產者、消費者交換的數據結構private List<String> buffer;//步生產者和消費者的交換對象private Exchanger<List<String>> exchanger;Producer(List<String> buffer,Exchanger<List<String>> exchanger){this.buffer = buffer;this.exchanger = exchanger;}@Overridepublic void run() {for(int i = 1 ; i < 5 ; i++){System.out.println("生產者第" + i + "次提供");for(int j = 1 ; j <= 3 ; j++){System.out.println("生產者裝入" + i + "--" + j);buffer.add("buffer：" + i + "--" + j);}System.out.println("生產者裝滿，等待與消費者交換...");try {exchanger.exchange(buffer);} catch (InterruptedException e) {e.printStackTrace();}}}}static class Consumer implements Runnable {private List<String> buffer;private final Exchanger<List<String>> exchanger;public Consumer(List<String> buffer, Exchanger<List<String>> exchanger) {this.buffer = buffer;this.exchanger = exchanger;}@Overridepublic void run() {for (int i = 1; i < 5; i++) {//調用exchange()與消費者進行數據交換try {buffer = exchanger.exchange(buffer);} catch (InterruptedException e) {e.printStackTrace();}System.out.println("消費者第" + i + "次提取");for (int j = 1; j <= 3 ; j++) {System.out.println("消費者 : " + buffer.get(0));buffer.remove(0);}}}}public static void main(String[] args){List<String> buffer1 = new ArrayList<String>();List<String> buffer2 = new ArrayList<String>();Exchanger<List<String>> exchanger = new Exchanger<List<String>>();Thread producerThread = new Thread(new Producer(buffer1,exchanger));Thread consumerThread = new Thread(new Consumer(buffer2,exchanger));producerThread.start();consumerThread.start();} } 生產者第1次提供 生產者裝入1--1 生產者裝入1--2 生產者裝入1--3 生產者裝滿，等待與消費者交換... 生產者第2次提供 消費者第1次提取 生產者裝入2--1 消費者 : buffer：1--1 生產者裝入2--2 生產者裝入2--3 生產者裝滿，等待與消費者交換... 消費者 : buffer：1--2 消費者 : buffer：1--3 消費者第2次提取 消費者 : buffer：2--1 消費者 : buffer：2--2 消費者 : buffer：2--3 生產者第3次提供 生產者裝入3--1 生產者裝入3--2 生產者裝入3--3 生產者裝滿，等待與消費者交換... 生產者第4次提供 生產者裝入4--1 生產者裝入4--2 生產者裝入4--3 生產者裝滿，等待與消費者交換... 消費者第3次提取 消費者 : buffer：3--1 消費者 : buffer：3--2 消費者 : buffer：3--3 消費者第4次提取 消費者 : buffer：4--1 消費者 : buffer：4--2 消費者 : buffer：4--3

?

轉載于:https://www.cnblogs.com/chihirotan/p/8528148.html

總結

以上是生活随笔為你收集整理的j.u.c系列（11）---之并发工具类：Exchanger的全部內容，希望文章能夠幫你解決所遇到的問題。

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