(十二)java多線程之Exchanger

Flands 發(fā)布于2019-08-16 10:31 / 3378人閱讀

摘要：本人郵箱歡迎轉(zhuǎn)載轉(zhuǎn)載請(qǐng)注明網(wǎng)址代碼已經(jīng)全部托管有需要的同學(xué)自行下載引言今天我們講最后一個(gè)同步工具類這個(gè)比較簡(jiǎn)單就是讓兩個(gè)線程交換數(shù)據(jù)理論只有兩個(gè)方法而已而且兩個(gè)還是一樣的只是參數(shù)不通而已跟另外一個(gè)線程交換數(shù)據(jù)如果另外一個(gè)線程的數(shù)據(jù)準(zhǔn)備好那么

本人郵箱: 
歡迎轉(zhuǎn)載,轉(zhuǎn)載請(qǐng)注明網(wǎng)址 http://blog.csdn.net/tianshi_kco
github: https://github.com/kco1989/kco
代碼已經(jīng)全部托管github有需要的同學(xué)自行下載

引言

今天我們講最后一個(gè)同步工具類Exchanger,這個(gè)比較簡(jiǎn)單,就是讓兩個(gè)線程交換數(shù)據(jù).

理論

Exchanger只有兩個(gè)方法而已,而且兩個(gè)還是一樣的,只是參數(shù)不通而已

exchange(V x) 跟另外一個(gè)線程交換數(shù)據(jù)x,如果另外一個(gè)線程的數(shù)據(jù)準(zhǔn)備好,那么當(dāng)前線程會(huì)立刻返回,并獲得另外一個(gè)線程的數(shù)據(jù);否則當(dāng)前線程會(huì)進(jìn)入等待狀態(tài)

V exchange(V x, long timeout, TimeUnit unit): 跟exchange,如果會(huì)有一個(gè)指定的超時(shí)時(shí)間,如果在等待時(shí)間超時(shí)了,而且還沒(méi)有收到對(duì)方的數(shù)據(jù)的話,則會(huì)拋出TimeoutException異常

例子有耐心的山治和路飛

看過(guò)海賊王的人都知道山治和路飛,山治是一個(gè)廚師,手藝那是杠杠的.路飛則是一個(gè)大胃王,超能吃.現(xiàn)在編寫一個(gè)程序,讓山治不斷給路飛做食物,而路飛不斷吃,吃完之后要對(duì)山治說(shuō)感謝.ok,開始編碼

先編寫一個(gè)Food食物類,這個(gè)比較簡(jiǎn)單,就是定義一些食物

public class Food {
    public final static String[] food = {
            "打邊爐","奶味蘆筍湯","糟片鴨","烤花攬桂魚","苦中作樂(lè)","七星丸","鴨黃豆腐","貝絲扒菜膽","脆炒南瓜絲","龍鳳雙腿",
            //省略部分代碼....
    };

    private static Random random = new Random();
    public static String getRandomFood(){
        return food[random.nextInt(food.length)];
    }
}

之后編寫山治做菜的類 ShanZhiRunnable

public class ShanZhiRunnable implements Runnable{
    Exchanger exchanger;
    Random random = new Random();
    public ShanZhiRunnable(Exchanger exchanger) {
        this.exchanger = exchanger;
    }

    @Override
    public void run() {
        while (true){
            try {
                String food = Food.getRandomFood();
                System.out.println("==>山治開始做 " + food);
                Thread.sleep(random.nextInt(500));
                System.out.println("==>山治把 " + food + " 給做好了,給路飛送過(guò)去");
                String exchange = exchanger.exchange(food);
                System.out.println("==>山治收到路飛的評(píng)語(yǔ):" + exchange);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }

    }
}

然后編寫路飛吃飯的類 LuFeiRunnable

public class LuFeiRunnable implements Runnable{
    Exchanger exchanger;
    Random random = new Random();
    public LuFeiRunnable(Exchanger exchanger) {
        this.exchanger = exchanger;
    }

    @Override
    public void run() {
        String temp = "開吃啦...";
        while (true){
            try {
                String food = exchanger.exchange(temp);
                System.out.println("--->路飛拿到山治做的菜: " + food);
                Thread.sleep(random.nextInt(500));
                System.out.println("--->路飛吃完" + food);
                temp = food + "太好吃!太感謝山治了...";
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}

最后編寫測(cè)試類 TestMain

public class TestMain {
    public static void main(String[] args) {
        Exchanger exchanger = new Exchanger<>();
        new Thread(new LuFeiRunnable(exchanger)).start();
        new Thread(new ShanZhiRunnable(exchanger)).start();
    }
}

運(yùn)行結(jié)果如下,并截取部分輸出

==>山治開始做 一品鮑魚
==>山治把 一品鮑魚 給做好了,給路飛送過(guò)去
==>山治收到路飛的評(píng)語(yǔ):開吃啦...
==>山治開始做 芝麻肉絲
--->路飛拿到山治做的菜: 一品鮑魚
==>山治把 芝麻肉絲 給做好了,給路飛送過(guò)去
--->路飛吃完一品鮑魚
--->路飛拿到山治做的菜: 芝麻肉絲
==>山治收到路飛的評(píng)語(yǔ):一品鮑魚太好吃!太感謝山治了...
==>山治開始做 雞蛋炒西紅柿
--->路飛吃完芝麻肉絲
==>山治把 雞蛋炒西紅柿 給做好了,給路飛送過(guò)去
==>山治收到路飛的評(píng)語(yǔ):芝麻肉絲太好吃!太感謝山治了...
--->路飛拿到山治做的菜: 雞蛋炒西紅柿
==>山治開始做 油豆腐鑲?cè)?==>山治把 油豆腐鑲?cè)?給做好了,給路飛送過(guò)去
--->路飛吃完雞蛋炒西紅柿
--->路飛拿到山治做的菜: 油豆腐鑲?cè)?==>山治收到路飛的評(píng)語(yǔ):雞蛋炒西紅柿太好吃!太感謝山治了...
==>山治開始做 梅菜蒸魚尾
==>山治把 梅菜蒸魚尾 給做好了,給路飛送過(guò)去
--->路飛吃完油豆腐鑲?cè)?==>山治收到路飛的評(píng)語(yǔ):油豆腐鑲?cè)馓贸?太感謝山治了...
==>山治開始做 炸子雞
--->路飛拿到山治做的菜: 梅菜蒸魚尾
==>山治把 炸子雞 給做好了,給路飛送過(guò)去
--->路飛吃完梅菜蒸魚尾
--->路飛拿到山治做的菜: 炸子雞
==>山治收到路飛的評(píng)語(yǔ):梅菜蒸魚尾太好吃!太感謝山治了...
==>山治開始做 翠竹粉蒸魚
==>山治把 翠竹粉蒸魚 給做好了,給路飛送過(guò)去
--->路飛吃完炸子雞
--->路飛拿到山治做的菜: 翠竹粉蒸魚
==>山治收到路飛的評(píng)語(yǔ):炸子雞太好吃!太感謝山治了...
==>山治開始做 風(fēng)情羊柳
==>山治把 風(fēng)情羊柳 給做好了,給路飛送過(guò)去

例子2 沒(méi)耐心的山治和路飛

現(xiàn)在假設(shè)他們倆都沒(méi)有耐心,不想一直等一下

將LuFeiRunnable修改為:

public class LuFeiRunnable implements Runnable{
    Exchanger exchanger;
    Random random = new Random();
    public LuFeiRunnable(Exchanger exchanger) {
        this.exchanger = exchanger;
    }

    @Override
    public void run() {
        String temp = "開吃啦...";
        while (true){
            try {
                String food = exchanger.exchange(temp, 300, TimeUnit.MILLISECONDS);
                System.out.println("--->路飛吃完" + food);
                temp = food + "太好吃!太感謝山治了...";
                Thread.sleep(random.nextInt(500));
            } catch (InterruptedException e) {
                e.printStackTrace();
            } catch (TimeoutException e) {
                System.out.println("--->路飛等的不耐煩了,不想等......開始喝起 東北風(fēng)" );
            }
        }
    }
}

將ShanZhiRunnable修改為

public class ShanZhiRunnable implements Runnable{
    Exchanger exchanger;
    Random random = new Random();
    public ShanZhiRunnable(Exchanger exchanger) {
        this.exchanger = exchanger;
    }

    @Override
    public void run() {
        while (true){
            String food = Food.getRandomFood();
            try {
                System.out.println("==>山治開始做 " + food);
                Thread.sleep(random.nextInt(500));
                System.out.println("==>山治把 " + food + " 給做好了,給路飛送過(guò)去");
                String exchange = exchanger.exchange(food, 300, TimeUnit.MILLISECONDS);
                System.out.println("==>山治收到路飛的評(píng)語(yǔ):" + exchange);
            } catch (InterruptedException e) {
                e.printStackTrace();
            } catch (TimeoutException e) {
                System.out.println("==>山治等的不耐煩了,不想等......,把 " + food + " 其他船員吃了");
            }
        }

    }
}

運(yùn)行一下程序:

==>山治開始做 辣子肉丁
--->路飛等的不耐煩了,不想等......開始喝起 東北風(fēng)
==>山治把 辣子肉丁 給做好了,給路飛送過(guò)去
==>山治收到路飛的評(píng)語(yǔ):開吃啦...
==>山治開始做 砂鍋三味
--->路飛吃完辣子肉丁
==>山治把 砂鍋三味 給做好了,給路飛送過(guò)去
==>山治收到路飛的評(píng)語(yǔ):辣子肉丁太好吃!太感謝山治了...
--->路飛吃完砂鍋三味
==>山治開始做 甜椒肉絲
==>山治把 甜椒肉絲 給做好了,給路飛送過(guò)去
--->路飛吃完甜椒肉絲
==>山治收到路飛的評(píng)語(yǔ):砂鍋三味太好吃!太感謝山治了...
==>山治開始做 一品鮑魚
==>山治把 一品鮑魚 給做好了,給路飛送過(guò)去
==>山治等的不耐煩了,不想等......,把 一品鮑魚 其他船員吃了
==>山治開始做 香酥鳳腿
--->路飛等的不耐煩了,不想等......開始喝起 東北風(fēng)
==>山治把 香酥鳳腿 給做好了,給路飛送過(guò)去
==>山治收到路飛的評(píng)語(yǔ):甜椒肉絲太好吃!太感謝山治了...
--->路飛吃完香酥鳳腿
==>山治開始做 雪花片湯
==>山治把 雪花片湯 給做好了,給路飛送過(guò)去
--->路飛吃完雪花片湯
==>山治收到路飛的評(píng)語(yǔ):香酥鳳腿太好吃!太感謝山治了...
==>山治開始做 鳳尾金魚
==>山治把 鳳尾金魚 給做好了,給路飛送過(guò)去
==>山治收到路飛的評(píng)語(yǔ):雪花片湯太好吃!太感謝山治了...
--->路飛吃完鳳尾金魚
==>山治開始做 三菇浸魚云
--->路飛等的不耐煩了,不想等......開始喝起 東北風(fēng)
==>山治把 三菇浸魚云 給做好了,給路飛送過(guò)去
==>山治收到路飛的評(píng)語(yǔ):鳳尾金魚太好吃!太感謝山治了...
--->路飛吃完三菇浸魚云
==>山治開始做 辣子雞丁
==>山治把 辣子雞丁 給做好了,給路飛送過(guò)去
==>山治收到路飛的評(píng)語(yǔ):三菇浸魚云太好吃!太感謝山治了...
--->路飛吃完辣子雞丁
==>山治開始做 梅干菜燒肉

通過(guò)以上兩個(gè)例子,掌握Exchanger應(yīng)該沒(méi)有什么難度.好的,這篇就到這里.

打賞

如果覺(jué)得我的文章寫的還過(guò)得去的話,有錢就捧個(gè)錢場(chǎng),沒(méi)錢給我捧個(gè)人場(chǎng)(幫我點(diǎn)贊或推薦一下)

云服務(wù)器 GPU云服務(wù)器 java多線程多線程調(diào)試 java java多線程分發(fā) java多線程并發(fā)

文章版權(quán)歸作者所有，未經(jīng)允許請(qǐng)勿轉(zhuǎn)載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。

轉(zhuǎn)載請(qǐng)注明本文地址：http://systransis.cn/yun/69925.html

發(fā)表評(píng)論

登陸后可評(píng)論

0條評(píng)論

Flands

男|高級(jí)講師

我要關(guān)注我要私信

TA的文章

重慶市POI數(shù)據(jù)

閱讀 2572·2021-11-23 09:51
BREW手機(jī)的移植

閱讀 3366·2021-11-22 15:22
阿里云雙11返場(chǎng)活動(dòng)：2核4G輕量服務(wù)器僅204元/3年;ECS云服務(wù)器低至174元/3年

閱讀 1880·2021-11-18 13:22
高效學(xué)習(xí) & 程序員練級(jí)攻略

閱讀 2277·2021-09-24 09:48
css名方法-命名的模塊化

閱讀 1321·2019-08-29 13:58
原生JS實(shí)現(xiàn)滑動(dòng)輪播圖

閱讀 1316·2019-08-26 13:39
Javascript拿到里目標(biāo)元素最近的符合條件的祖先元素

閱讀 2455·2019-08-26 10:48
【ES6腳丫系列】Symbol

閱讀 3042·2019-08-26 10:21

成人国产在线小视频_日韩寡妇人妻调教在线播放_色成人www永久在线观看_2018国产精品久久_亚洲欧美高清在线30p_亚洲少妇综合一区_黄色在线播放国产_亚洲另类技巧小说校园_国产主播xx日韩_a级毛片在线免费

資訊專欄INFORMATION COLUMN

上云采購(gòu)季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺(tái)、長(zhǎng)期優(yōu)惠，快來(lái)選購(gòu)！

(十二)java多線程之Exchanger

相關(guān)文章

Java多線程編程之同步器

**(十五)java多線程之并發(fā)集合ArrayBlockingQueue**

Java多線程進(jìn)階（一）—— J.U.C并發(fā)包概述

Java Exchanger交換線程

***java并發(fā)編程學(xué)習(xí)之Exchanger***

發(fā)表評(píng)論

0條評(píng)論

Flands

男|高級(jí)講師

TA的文章

重慶市POI數(shù)據(jù)

BREW手機(jī)的移植

阿里云雙11返場(chǎng)活動(dòng)：2核4G輕量服務(wù)器僅204元/3年;ECS云服務(wù)器低至174元/3年

高效學(xué)習(xí) & 程序員練級(jí)攻略

css名方法-命名的模塊化

原生JS實(shí)現(xiàn)滑動(dòng)輪播圖

Javascript拿到里目標(biāo)元素最近的符合條件的祖先元素

【ES6腳丫系列】Symbol

最新活動(dòng)

資訊專欄INFORMATION COLUMN

上云采購(gòu)季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺(tái)、長(zhǎng)期優(yōu)惠，快來(lái)選購(gòu)！

(十二)java多線程之Exchanger

相關(guān)文章

發(fā)表評(píng)論

0條評(píng)論

男|高級(jí)講師

TA的文章

最新活動(dòng)

上云采購(gòu)季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺(tái)、長(zhǎng)期優(yōu)惠，快來(lái)選購(gòu)！