Exchanger的使用
生活随笔
收集整理的這篇文章主要介紹了
Exchanger的使用
小編覺得挺不錯的,現在分享給大家,幫大家做個參考.
兩個線程可以交換對象的同步點。每個線程都在進入 exchange方法時給出某個對象,并接受其他線程返回時給出的對象。
用于實現兩個人之間的數據交換,每個人在完成一定的事務后想與對方交換數據,第一個先拿出數據的人將一直等待第二個人拿著數據到來時,才能彼此交換數據。| **[Exchanger](http://www.cnblogs.com/java/util/concurrent/Exchanger.html#Exchanger())**() ????????? 創建一個新的 Exchanger。 |
?
| [V](http://www.cnblogs.com/java/util/concurrent/Exchanger.html "Exchanger 中的類型參數") | **[exchange](http://www.cnblogs.com/java/util/concurrent/Exchanger.html#exchange(V))**([V](http://www.cnblogs.com/java/util/concurrent/Exchanger.html "Exchanger 中的類型參數") x) ????????? 等待另一個線程到達此交換點(除非它被中斷)),然后將給定的對象傳送給該線程,并接收該線程的對象。 |
| [V](http://www.cnblogs.com/java/util/concurrent/Exchanger.html "Exchanger 中的類型參數") | **[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 中的類型參數") x, long timeout, [TimeUnit](http://www.cnblogs.com/java/util/concurrent/TimeUnit.html "java.util.concurrent 中的枚舉") unit) ????????? 等待另一個線程到達此交換點(除非它被中斷),或者超出了指定的等待時間),然后將給定的對象傳送給該線程,同時接收該線程的對象。 |
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 “正在把數據” + data1 +”換出去”); 18 String data2 = (String)exchanger.exchange(data1); 19 System.out.println(“線程” + Thread.currentThread().getName() + 20 “換回的數據為” + 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 = “lhm”; 31 System.out.println(“線程” + Thread.currentThread().getName() + 32 “正在把數據” + data1 +”換出去”); 33 String data2 = (String)exchanger.exchange(data1); 34 System.out.println(“線程” + Thread.currentThread().getName() + 35 “換回的數據為” + data2); 36 }catch(Exception e){ 37 38 } 39 } 40 }); 41 } 42 }
運行結果如下:
總結
以上是生活随笔為你收集整理的Exchanger的使用的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: 完美世界第二题:模拟读数字
- 下一篇: jmeter --上传文件