本文研究的主要是Java編程線程同步工具Exchanger的使用，下面看看具體內(nèi)容。
如果兩個線程在運(yùn)行過程中需要交換彼此的信息，比如一個數(shù)據(jù)或者使用的空間，就需要用到Exchanger這個類，Exchanger為線程交換信息提供了非常方便的途徑，它可以作為兩個線程交換對象的同步點(diǎn)，只有當(dāng)每個線程都在進(jìn)入 exchange ()方法并給出對象時，才能接受其他線程返回時給出的對象。
每次只能兩個線程交換數(shù)據(jù)，如果有多個線程，也只有兩個能交換數(shù)據(jù)。下面看個通俗的例子：一手交錢一首交貨！
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
|
public class ExchangerTest { public static void main(String[] args) { ExecutorService service = Executors.newCachedThreadPool(); final Exchanger exchanger = new Exchanger(); //定義一個交換對象，用來交換數(shù)據(jù) //開啟一個線程執(zhí)行任務(wù) service.execute(new Runnable(){ @Override public void run() { try { String data1 = "海洛因"; System.out.println("線程" + Thread.currentThread().getName() + "正在把毒品" + data1 + "拿出來"); Thread.sleep((long)(Math.random()*10000)); //把要交換的數(shù)據(jù)傳到exchange方法中，然后被阻塞，等待另一個線程與之交換。返回交換后的數(shù)據(jù) String data2 = (String)exchanger.exchange(data1); System.out.println("線程" + Thread.currentThread().getName() + "用海洛因換來了" + data2); } catch(Exception e){ } finally { service.shutdown(); System.out.println("交易完畢，拿著錢快跑！"); } } } ); //開啟另一個線程執(zhí)行任務(wù) service.execute(new Runnable(){ @Override public void run() { try { String data1 = "300萬"; System.out.println("線程" + Thread.currentThread().getName() + "正在把" + data1 +"拿出來"); Thread.sleep((long)(Math.random()*10000)); String data2 = (String)exchanger.exchange(data1); System.out.println("線程" + Thread.currentThread().getName() + "用300萬弄到了" + data2); } catch(Exception e){ } finally { service.shutdown(); System.out.println("交易完畢，拿著海洛因快跑！"); } } } ); }} |
從代碼中我仿佛看到了兩個人在交易毒品的場面……來看一下交易結(jié)果如何：
線程pool-1-thread-1正在把毒品海洛因拿出來
線程pool-1-thread-2正在把300萬拿出來
線程pool-1-thread-2用300萬弄到了海洛因
線程pool-1-thread-1用海洛因換來了300萬
交易完畢，拿著海洛因快跑！
交易完畢，拿著錢快跑！
跑的倒是快，從運(yùn)行結(jié)果來看，確實(shí)實(shí)現(xiàn)了數(shù)據(jù)的交換，這個只是交換一個基本類型的數(shù)據(jù)而已，它真正的用處不僅僅局限于此，比如我們可以交換一個對象，這就有用了，JDK官方提到了一個高級的應(yīng)用：
使用 Exchanger 在線程間交換緩沖區(qū)，因此，在需要時，填充緩沖區(qū)的線程獲取一個新騰空的緩沖區(qū)，并將填滿的緩沖區(qū)傳遞給騰空緩沖區(qū)的線程。
這就得根據(jù)實(shí)際情況了，思想和上面的一樣，實(shí)際中肯定要定義一個緩沖區(qū)的類，然后兩個線程之間交換的就是這個緩沖區(qū)的類即可，至于類中如何實(shí)現(xiàn)，就得看實(shí)際情況了。Exchanger的使用就總結(jié)這么多吧~
總結(jié)
以上就是本文關(guān)于Java編程線程同步工具Exchanger的使用實(shí)例解析的全部內(nèi)容，希望對大家有所幫助。感興趣的朋友可以繼續(xù)參閱本站其他相關(guān)專題，如有不足之處，歡迎留言指出。感謝朋友們對本站的支持！
原文鏈接：http://blog.csdn.net/eson_15/article/details/51581842
