【原】Java并發程序的一個使用Exchanger的實例

今天看了些Exchanger的資料，有個喝水的例子不錯。我這里細化了以下，并得到實現。

思路：

有一個Drinker和一個Waiter，有兩個杯子，一個空杯子，一個杯子有3升水，Drinker一次喝1升水，要耗時1秒，Waiter一次可以倒1升水，一次耗時1秒。開始時，他們各持一個杯子，Drinker持有3升水的杯子，Waiter持有空杯子。然后開始喝水，當有一個杯子里沒水了，整個程序結束。

方法：

Exchanger主要用于交換兩個線程的同類型的共享數據，喝水這個例子很好的表現了Exchanger的作用。

【注：】程序中的數據可以自己調整來，整體體現了動態交換杯子的效果。

import java.util.concurrent.Exchanger;

import java.util.concurrent.ExecutorService;

import java.util.concurrent.Executors;

import java.util.concurrent.TimeUnit;

class Cup {

int waterVolume = 0;

String cupName="";

public String getCupName() {

return cupName;

}

public void setCupName(String cupName) {

this.cupName = cupName;

}

Cup(int i ,String name){

waterVolume=i;

cupName=name;

}

@Override

public String toString() {

// TODO Auto-generated method stub

return cupName+"有"+waterVolume+"升水！";

}

public int getWaterVolume() {

return waterVolume;

}

public void drinkWater(){

waterVolume--;

}

public void drinkWater( int i ){

if((waterVolume-i)>=0){

waterVolume-=i;

}else{

System.out.println("沒有這么多水可以喝！！！");

return;

}

}

public void addWater(){

waterVolume++;

}

public void addWater(int i){

waterVolume=i;

}

}

class Drinker implements Runnable{

Cup currentCup;

Exchanger ex;

Drinker(Exchanger ex,Cup c){

currentCup= c;

this.ex= ex;

}

@Override

public void run() {

//得到杯子喝水

/*try {

currentCup = (Cup)ex.exchange(currentCup);

} catch (InterruptedException e1) {

// TODO Auto-generated catch block

e1.printStackTrace();

}*/

boolean flag = true;

while(flag){

if(currentCup.getWaterVolume() > 0){

System.out.println("喝水者："+currentCup);

System.out.println("喝水者：從"+currentCup.getCupName()+"喝2升水，喝水用時1秒");

currentCup.drinkWater(2);

try {

TimeUnit.SECONDS.sleep(1);

} catch (InterruptedException e) {

// TODO: handle exception

e.printStackTrace();

}

}

if(currentCup.getWaterVolume() == 0){

System.out.println("喝水者："+currentCup+",水喝光了！別加了！");

flag=false;

}

//服務員加完水后的杯子

try {

currentCup = (Cup)ex.exchange(currentCup);

} catch (InterruptedException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

}

}

}

class Waiter implements Runnable{

Cup currentCup;

Exchanger ex;

Waiter(Exchanger ex,Cup c){

currentCup= c;

this.ex= ex;

}

@Override

public void run() {

//得到杯子加水

/*try {

currentCup = (Cup)ex.exchange(currentCup);

} catch (InterruptedException e1) {

// TODO Auto-generated catch block

e1.printStackTrace();

}*/

boolean flag = true;

while(flag){

System.out.println("服務員："+currentCup);

System.out.println("服務員：倒入"+currentCup.getCupName()+" 1升水，耗時1秒");

try {

TimeUnit.SECONDS.sleep(1);

} catch (InterruptedException e) {

// TODO: handle exception

e.printStackTrace();

}

currentCup.addWater();

//得到顧客遞過來的杯子

try {

currentCup=(Cup)ex.exchange(currentCup);

} catch (InterruptedException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

if(currentCup.getWaterVolume() == 0){

System.out.println("服務員："+currentCup+"水喝光了！！不加了！");

flag=false;

}

}

}

}

public class DrinkWaterDemo {

public static void main(String[] args) {

Cup cup1 = new Cup(3,"cup1");

Cup cup2 = new Cup(0,"cup2");

final Exchanger ec = new Exchanger();

ExecutorService es = Executors.newFixedThreadPool(2);

es.submit(new Waiter(ec,cup2));

es.submit(new Drinker(ec, cup1));

es.shutdown();

}

}

總結

以上是生活随笔為你收集整理的exchange java对象,【原】Java并发程序的一个应用Exchanger的实例的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。