兩個(gè)線程可以交換對(duì)象的同步點(diǎn)。每個(gè)線程都在進(jìn)入 exchange方法時(shí)給出某個(gè)對(duì)象，并接受其他線程返回時(shí)給出的對(duì)象。

用于實(shí)現(xiàn)兩個(gè)人之間的數(shù)據(jù)交換，每個(gè)人在完成一定的事務(wù)后想與對(duì)方交換數(shù)據(jù)，第一個(gè)先拿出數(shù)據(jù)的人將一直等待第二個(gè)人拿著數(shù)據(jù)到來時(shí)，才能彼此交換數(shù)據(jù)。











構(gòu)造方法摘要

**[Exchanger](http://www.cnblogs.com/java/util/concurrent/Exchanger.html#Exchanger())**() ????????? 創(chuàng)建一個(gè)新的 Exchanger。

?

















方法摘要

[V](http://www.cnblogs.com/java/util/concurrent/Exchanger.html "Exchanger 中的類型參數(shù)")	**[exchange](http://www.cnblogs.com/java/util/concurrent/Exchanger.html#exchange(V))**([V](http://www.cnblogs.com/java/util/concurrent/Exchanger.html "Exchanger 中的類型參數(shù)") x) ????????? 等待另一個(gè)線程到達(dá)此交換點(diǎn)（除非它被中斷)），然后將給定的對(duì)象傳送給該線程，并接收該線程的對(duì)象。
[V](http://www.cnblogs.com/java/util/concurrent/Exchanger.html "Exchanger 中的類型參數(shù)")	**[exchange](http://www.cnblogs.com/java/util/concurrent/Exchanger.html#exchange(V, long, java.util.concurrent.TimeUnit))**([V](http://www.cnblogs.com/java/util/concurrent/Exchanger.html "Exchanger 中的類型參數(shù)") x, long timeout, [TimeUnit](http://www.cnblogs.com/java/util/concurrent/TimeUnit.html "java.util.concurrent 中的枚舉") unit) ????????? 等待另一個(gè)線程到達(dá)此交換點(diǎn)（除非它被中斷)，或者超出了指定的等待時(shí)間），然后將給定的對(duì)象傳送給該線程，同時(shí)接收該線程的對(duì)象。

1 package com.thread;2 import java.util.concurrent.Exchanger;3 import java.util.concurrent.ExecutorService;4 import java.util.concurrent.Executors;56 public class ExchangerTest {78 public static void main(String[] args) {9 ExecutorService service = Executors.newCachedThreadPool(); 10 final Exchanger exchanger = new Exchanger(); 11 service.execute(new Runnable(){ 12 public void run() { 13 try { 14 Thread.sleep((long)(Math.random()10000)); 15 String data1 = “zxx”; 16 System.out.println(“線程” + Thread.currentThread().getName() + 17 “正在把數(shù)據(jù)” + data1 +”換出去”); 18 String data2 = (String)exchanger.exchange(data1); 19 System.out.println(“線程” + Thread.currentThread().getName() + 20 “換回的數(shù)據(jù)為” + data2); 21 }catch(Exception e){ 22 23 } 24 } 25 }); 26 service.execute(new Runnable(){ 27 public void run() { 28 try { 29 Thread.sleep((long)(Math.random()10000)); 30 String data1 = “l(fā)hm”; 31 System.out.println(“線程” + Thread.currentThread().getName() + 32 “正在把數(shù)據(jù)” + data1 +”換出去”); 33 String data2 = (String)exchanger.exchange(data1); 34 System.out.println(“線程” + Thread.currentThread().getName() + 35 “換回的數(shù)據(jù)為” + data2); 36 }catch(Exception e){ 37 38 } 39 } 40 }); 41 } 42 }

運(yùn)行結(jié)果如下：

線程pool-1-thread-1正在把數(shù)據(jù)zxx換出去 線程pool-1-thread-2正在把數(shù)據(jù)lhm換出去 線程pool-1-thread-1換回的數(shù)據(jù)為lhm 線程pool-1-thread-2換回的數(shù)據(jù)為zxx

總結(jié)

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

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。