一区二区三区在线-一区二区三区亚洲视频-一区二区三区亚洲-一区二区三区午夜-一区二区三区四区在线视频-一区二区三区四区在线免费观看

服務器之家:專注于服務器技術及軟件下載分享
分類導航

PHP教程|ASP.NET教程|Java教程|ASP教程|編程技術|正則表達式|C/C++|IOS|C#|Swift|Android|VB|R語言|JavaScript|易語言|vb.net|

服務器之家 - 編程語言 - Java教程 - Java編程線程同步工具Exchanger的使用實例解析

Java編程線程同步工具Exchanger的使用實例解析

2021-04-01 14:38eson_15 Java教程

這篇文章主要介紹了Java編程線程同步工具Exchanger的使用實例解析,分享了相關代碼示例,小編覺得還是挺不錯的,具有一定借鑒價值,需要的朋友可以參考下

本文研究的主要是Java編程線程同步工具Exchanger的使用,下面看看具體內容。

  如果兩個線程在運行過程中需要交換彼此的信息,比如一個數據或者使用的空間,就需要用到Exchanger這個類,Exchanger為線程交換信息提供了非常方便的途徑,它可以作為兩個線程交換對象的同步點,只有當每個線程都在進入 exchange ()方法并給出對象時,才能接受其他線程返回時給出的對象。

  每次只能兩個線程交換數據,如果有多個線程,也只有兩個能交換數據。下面看個通俗的例子:一手交錢一首交貨!

?
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();
        //定義一個交換對象,用來交換數據
        //開啟一個線程執行任務
        service.execute(new Runnable(){
            @Override
                  public void run() {
                try {
                    String data1 = "海洛因";
                    System.out.println("線程" + Thread.currentThread().getName()
                                  + "正在把毒品" + data1 + "拿出來");
                    Thread.sleep((long)(Math.random()*10000));
                    //把要交換的數據傳到exchange方法中,然后被阻塞,等待另一個線程與之交換。返回交換后的數據
                    String data2 = (String)exchanger.exchange(data1);
                    System.out.println("線程" + Thread.currentThread().getName() +
                              "用海洛因換來了" + data2);
                }
                catch(Exception e){
                }
                finally {
                    service.shutdown();
                    System.out.println("交易完畢,拿著錢快跑!");
                }
            }
        }
        );
        //開啟另一個線程執行任務
        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("交易完畢,拿著海洛因快跑!");
                }
            }
        }
        );
    }
}

從代碼中我仿佛看到了兩個人在交易毒品的場面……來看一下交易結果如何:

線程pool-1-thread-1正在把毒品海洛因拿出來
線程pool-1-thread-2正在把300萬拿出來
線程pool-1-thread-2用300萬弄到了海洛因
線程pool-1-thread-1用海洛因換來了300萬
交易完畢,拿著海洛因快跑!
交易完畢,拿著錢快跑!

 跑的倒是快,從運行結果來看,確實實現了數據的交換,這個只是交換一個基本類型的數據而已,它真正的用處不僅僅局限于此,比如我們可以交換一個對象,這就有用了,JDK官方提到了一個高級的應用:

使用 Exchanger 在線程間交換緩沖區,因此,在需要時,填充緩沖區的線程獲取一個新騰空的緩沖區,并將填滿的緩沖區傳遞給騰空緩沖區的線程。

  這就得根據實際情況了,思想和上面的一樣,實際中肯定要定義一個緩沖區的類,然后兩個線程之間交換的就是這個緩沖區的類即可,至于類中如何實現,就得看實際情況了。Exchanger的使用就總結這么多吧~

總結

以上就是本文關于Java編程線程同步工具Exchanger的使用實例解析的全部內容,希望對大家有所幫助。感興趣的朋友可以繼續參閱本站其他相關專題,如有不足之處,歡迎留言指出。感謝朋友們對本站的支持!

原文鏈接:http://blog.csdn.net/eson_15/article/details/51581842

延伸 · 閱讀

精彩推薦
主站蜘蛛池模板: 精品国产国偷自产在线观看 | 韩国三级视频网站 | 亚洲高清视频免费 | 国产一二在线观看视频网站 | h玉足嫩脚嗯啊白丝 | 亚洲欧美一区二区三区在线观看 | 久久精品成人免费网站 | 午夜在线观看免费完整直播网页 | 91系列在线观看免费 | 国产精品亚洲片夜色在线 | 乌克兰黄色录像 | 国产成人久久久精品一区二区三区 | 日本又黄又裸一级大黄裸片 | 2019理论韩国理论中文 | 成人午夜爽爽爽免费视频 | 色噜噜国产精品视频一区二区 | 91无毒不卡| 国产图片综合区 | 国产精品视频自拍 | 国产伦久视频免费观看视频 | gaychinese男男2022 | 亚洲国产成人精品无码区5566 | 国产欧美一区二区三区久久 | 亚洲欧美专区精品伊人久久 | 日b视频免费看 | 99国产精品免费观看视频 | 扒开女人下面使劲桶屁股动漫 | 亚洲免费视频一区二区三区 | 欧美专区视频 | 天美影视文化传媒mv免费 | 亚洲 色 欧美 爱 视频 日韩 | 欧美精品久久一区二区三区 | 香蕉精品国产高清自在自线 | 日本午夜大片免费观看视频 | 五月婷婷在线免费观看 | mmkk在线看片 | 日韩精品中文字幕视频一区 | 午夜国产理论 | 亚洲精品久久久久福利网站 | 亚洲国产精品一在线观看 | 久久性综合亚洲精品电影网 |