摘要：本人郵箱歡迎轉載轉載請注明網址代碼已經全部托管有需要的同學自行下載引言今天我們講最后一個同步工具類這個比較簡單就是讓兩個線程交換數據理論只有兩個方法而已而且兩個還是一樣的只是參數不通而已跟另外一個線程交換數據如果另外一個線程的數據準備好那么
本人郵箱:
歡迎轉載,轉載請注明網址 http://blog.csdn.net/tianshi_kco
github: https://github.com/kco1989/kco
代碼已經全部托管github有需要的同學自行下載
引言
今天我們講最后一個同步工具類Exchanger,這個比較簡單,就是讓兩個線程交換數據.
理論
Exchanger只有兩個方法而已,而且兩個還是一樣的,只是參數不通而已
exchange(V x) 跟另外一個線程交換數據x,如果另外一個線程的數據準備好,那么當前線程會立刻返回,并獲得另外一個線程的數據;否則當前線程會進入等待狀態
V exchange(V x, long timeout, TimeUnit unit): 跟exchange,如果會有一個指定的超時時間,如果在等待時間超時了,而且還沒有收到對方的數據的話,則會拋出TimeoutException異常
例子 有耐心的山治和路飛
看過海賊王的人都知道山治和路飛,山治是一個廚師,手藝那是杠杠的.路飛則是一個大胃王,超能吃.現在編寫一個程序,讓山治不斷給路飛做食物,而路飛不斷吃,吃完之后要對山治說感謝.ok,開始編碼
先編寫一個Food食物類,這個比較簡單,就是定義一些食物
public class Food {
public final static String[] food = {
"打邊爐","奶味蘆筍湯","糟片鴨","烤花攬桂魚","苦中作樂","七星丸","鴨黃豆腐","貝絲扒菜膽","脆炒南瓜絲","龍鳳雙腿",
//省略部分代碼....
};
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 + " 給做好了,給路飛送過去");
String exchange = exchanger.exchange(food);
System.out.println("==>山治收到路飛的評語:" + 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();
}
}
}
}
最后編寫測試類 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();
}
}
運行結果如下,并截取部分輸出
==>山治開始做 一品鮑魚
==>山治把 一品鮑魚 給做好了,給路飛送過去
==>山治收到路飛的評語:開吃啦...
==>山治開始做 芝麻肉絲
--->路飛拿到山治做的菜: 一品鮑魚
==>山治把 芝麻肉絲 給做好了,給路飛送過去
--->路飛吃完一品鮑魚
--->路飛拿到山治做的菜: 芝麻肉絲
==>山治收到路飛的評語:一品鮑魚太好吃!太感謝山治了...
==>山治開始做 雞蛋炒西紅柿
--->路飛吃完芝麻肉絲
==>山治把 雞蛋炒西紅柿 給做好了,給路飛送過去
==>山治收到路飛的評語:芝麻肉絲太好吃!太感謝山治了...
--->路飛拿到山治做的菜: 雞蛋炒西紅柿
==>山治開始做 油豆腐鑲肉
==>山治把 油豆腐鑲肉 給做好了,給路飛送過去
--->路飛吃完雞蛋炒西紅柿
--->路飛拿到山治做的菜: 油豆腐鑲肉
==>山治收到路飛的評語:雞蛋炒西紅柿太好吃!太感謝山治了...
==>山治開始做 梅菜蒸魚尾
==>山治把 梅菜蒸魚尾 給做好了,給路飛送過去
--->路飛吃完油豆腐鑲肉
==>山治收到路飛的評語:油豆腐鑲肉太好吃!太感謝山治了...
==>山治開始做 炸子雞
--->路飛拿到山治做的菜: 梅菜蒸魚尾
==>山治把 炸子雞 給做好了,給路飛送過去
--->路飛吃完梅菜蒸魚尾
--->路飛拿到山治做的菜: 炸子雞
==>山治收到路飛的評語:梅菜蒸魚尾太好吃!太感謝山治了...
==>山治開始做 翠竹粉蒸魚
==>山治把 翠竹粉蒸魚 給做好了,給路飛送過去
--->路飛吃完炸子雞
--->路飛拿到山治做的菜: 翠竹粉蒸魚
==>山治收到路飛的評語:炸子雞太好吃!太感謝山治了...
==>山治開始做 風情羊柳
==>山治把 風情羊柳 給做好了,給路飛送過去
例子2 沒耐心的山治和路飛
現在假設他們倆都沒有耐心,不想一直等一下
將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("--->路飛等的不耐煩了,不想等......開始喝起 東北風" );
}
}
}
}
將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 + " 給做好了,給路飛送過去");
String exchange = exchanger.exchange(food, 300, TimeUnit.MILLISECONDS);
System.out.println("==>山治收到路飛的評語:" + exchange);
} catch (InterruptedException e) {
e.printStackTrace();
} catch (TimeoutException e) {
System.out.println("==>山治等的不耐煩了,不想等......,把 " + food + " 其他船員吃了");
}
}
}
}
運行一下程序:
==>山治開始做 辣子肉丁
--->路飛等的不耐煩了,不想等......開始喝起 東北風
==>山治把 辣子肉丁 給做好了,給路飛送過去
==>山治收到路飛的評語:開吃啦...
==>山治開始做 砂鍋三味
--->路飛吃完辣子肉丁
==>山治把 砂鍋三味 給做好了,給路飛送過去
==>山治收到路飛的評語:辣子肉丁太好吃!太感謝山治了...
--->路飛吃完砂鍋三味
==>山治開始做 甜椒肉絲
==>山治把 甜椒肉絲 給做好了,給路飛送過去
--->路飛吃完甜椒肉絲
==>山治收到路飛的評語:砂鍋三味太好吃!太感謝山治了...
==>山治開始做 一品鮑魚
==>山治把 一品鮑魚 給做好了,給路飛送過去
==>山治等的不耐煩了,不想等......,把 一品鮑魚 其他船員吃了
==>山治開始做 香酥鳳腿
--->路飛等的不耐煩了,不想等......開始喝起 東北風
==>山治把 香酥鳳腿 給做好了,給路飛送過去
==>山治收到路飛的評語:甜椒肉絲太好吃!太感謝山治了...
--->路飛吃完香酥鳳腿
==>山治開始做 雪花片湯
==>山治把 雪花片湯 給做好了,給路飛送過去
--->路飛吃完雪花片湯
==>山治收到路飛的評語:香酥鳳腿太好吃!太感謝山治了...
==>山治開始做 鳳尾金魚
==>山治把 鳳尾金魚 給做好了,給路飛送過去
==>山治收到路飛的評語:雪花片湯太好吃!太感謝山治了...
--->路飛吃完鳳尾金魚
==>山治開始做 三菇浸魚云
--->路飛等的不耐煩了,不想等......開始喝起 東北風
==>山治把 三菇浸魚云 給做好了,給路飛送過去
==>山治收到路飛的評語:鳳尾金魚太好吃!太感謝山治了...
--->路飛吃完三菇浸魚云
==>山治開始做 辣子雞丁
==>山治把 辣子雞丁 給做好了,給路飛送過去
==>山治收到路飛的評語:三菇浸魚云太好吃!太感謝山治了...
--->路飛吃完辣子雞丁
==>山治開始做 梅干菜燒肉
通過以上兩個例子,掌握Exchanger應該沒有什么難度.好的,這篇就到這里.
打賞
如果覺得我的文章寫的還過得去的話,有錢就捧個錢場,沒錢給我捧個人場(幫我點贊或推薦一下)
文章版權歸作者所有，未經允許請勿轉載,若此文章存在違規行為，您可以聯系管理員刪除。
轉載請注明本文地址：http://specialneedsforspecialkids.com/yun/69925.html
