码迷,mamicode.com
首页 > 编程语言 > 详细

Java - wait()/notify()

时间:2015-12-30 17:04:51      阅读:155      评论:0      收藏:0      [点我收藏+]

标签:

 

1、wait()惯用法:wait()包装在一个while语句中,因为某个其他任务可能会在WaitPerson被唤醒时,会突然插足并拿走订单;

2、只能在同步控制方法或同步控制块里调用wait()、notify()和notifyAll();

import java.util.concurrent.*;

public class Meal {
        private final int orderNum;
        public Meal(int orderNum){
            this.orderNum=orderNum;
        }
        public String toString(){
            return "Meal "+orderNum;
        }
}

public class Restaurant {
    Meal meal;
    ExecutorService exec=Executors.newCachedThreadPool();
    WaitPerson waitPerson=new WaitPerson(this);
    Chef chef=new Chef(this);
    
    public Restaurant(){
        exec.execute(waitPerson);
        exec.execute(chef);
    }
}

public class WaitPerson implements Runnable{

    private Restaurant restaurant;
    public  WaitPerson(Restaurant r) {
        restaurant=r;
    }
    
    @Override
    public void run() {
        try{
            while(!Thread.interrupted()){
                synchronized (this) {
                    while(restaurant.meal==null){
                        wait(); // for the chef to produce a meal
                    }
                }
                System.out.println("WaitPerson got "+restaurant.meal);
                
                synchronized(restaurant.chef){
                    restaurant.meal=null;
                    restaurant.chef.notifyAll(); 
                }
            }
        }catch(InterruptedException e){
            System.out.println("WaitPerson interrupted");
        }    
    }
}

public class Chef implements Runnable {

    private Restaurant restaurant;
    private int count=0;
    public Chef(Restaurant r){
        restaurant=r;
    }
    
    @Override
    public void run() {
        try{
            while(!Thread.interrupted()){
                synchronized(this){
                    while(restaurant.meal!=null){
                        wait();
                    }
                }
                
                if(++count==10){
                    System.out.println("Out of food.closing");
                    restaurant.exec.shutdownNow();
                }
                
                System.out.print("Order up! ");
                
                synchronized(restaurant.waitPerson){
                    restaurant.meal=new Meal(count);
                    restaurant.waitPerson.notifyAll();
                }
                
                //TimeUnit.MILLISECONDS.sleep(100);
            }
        }catch(InterruptedException e){
            System.out.println("Chef interrupted");
        }
    }
}

 

Java - wait()/notify()

标签:

原文地址:http://www.cnblogs.com/null2/p/5089219.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!