【原】Java并發(fā)程序的一個(gè)使用Exchanger的實(shí)例

今天看了些Exchanger的資料，有個(gè)喝水的例子不錯(cuò)。我這里細(xì)化了以下，并得到實(shí)現(xiàn)。

思路：

有一個(gè)Drinker和一個(gè)Waiter，有兩個(gè)杯子，一個(gè)空杯子，一個(gè)杯子有3升水，Drinker一次喝1升水，要耗時(shí)1秒，Waiter一次可以倒1升水，一次耗時(shí)1秒。開(kāi)始時(shí)，他們各持一個(gè)杯子，Drinker持有3升水的杯子，Waiter持有空杯子。然后開(kāi)始喝水，當(dāng)有一個(gè)杯子里沒(méi)水了，整個(gè)程序結(jié)束。

方法：

Exchanger主要用于交換兩個(gè)線程的同類型的共享數(shù)據(jù)，喝水這個(gè)例子很好的表現(xiàn)了Exchanger的作用。

【注：】程序中的數(shù)據(jù)可以自己調(diào)整來(lái)，整體體現(xiàn)了動(dòng)態(tài)交換杯子的效果。

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("沒(méi)有這么多水可以喝！！！");

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升水，喝水用時(shí)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;

}

//服務(wù)員加完水后的杯子

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("服務(wù)員："+currentCup);

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

try {

TimeUnit.SECONDS.sleep(1);

} catch (InterruptedException e) {

// TODO: handle exception

e.printStackTrace();

}

currentCup.addWater();

//得到顧客遞過(guò)來(lái)的杯子

try {

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

} catch (InterruptedException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

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

System.out.println("服務(wù)員："+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();

}

}

總結(jié)

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

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。