Exchanger可以在兩個線程之間交換數據，只能是2個線程，他不支持更多的線程之間互換數據。

當線程A調用Exchange對象的exchange()方法后，他會陷入阻塞狀態，直到線程B也調用了exchange()方法，然后以線程安全的方式交換數據，之后線程A和B繼續運行。

1 package cn.sp.test4; 2 3 import java.util.ArrayList; 4 import java.util.List; 5 import java.util.concurrent.Exchanger; 6 7 /** 8 * Created by 2YSP on 2017/9/1. 9 * 兩個線程之間交換數據 10 */ 11 public class ExchangerTest { 12 13 14 public static void main(String[] args) { 15 final Exchanger<List<Integer>> exchanger = new Exchanger<>(); 16 17 new Thread(() -> { 18 List<Integer> l = new ArrayList<Integer>(2); 19 l.add(1); 20 l.add(2); 21 try { 22 l = exchanger.exchange(l); 23 } catch (InterruptedException e) { 24 e.printStackTrace(); 25 } 26 System.out.println("thread1: " + l); 27 }).start(); 28 29 new Thread(() -> { 30 List<Integer> l = new ArrayList<Integer>(2); 31 l.add(3); 32 l.add(4); 33 try { 34 l = exchanger.exchange(l); 35 } catch (InterruptedException e) { 36 e.printStackTrace(); 37 } 38 System.out.println("thread2: " + l); 39 }).start(); 40 41 } 42 }

執行結果：

可以看到線程1和2已經交換了數據。

轉載于:https://www.cnblogs.com/2YSP/p/7483584.html

總結

以上是生活随笔為你收集整理的concurrent包下的Exchanger练习的全部內容，希望文章能夠幫你解決所遇到的問題。

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