多線程 wait(),notify()方法,案例總結

廢話不多說,案例如下

package com.xujingyang.Exok;

/**
 * 商品類
 * @author 徐景洋
 */
public class Goods {
    private String pinpai;
    private String name;
    
    private int num;
    
    public int getNum() {
        return num;
    }
    public void setNum(int num) {
        this.num = num;
    }
    public String getPinpai() {
        return pinpai;
    }
    public void setPinpai(String pinpai) {
        this.pinpai = pinpai;
    }
    public String getName() {
        return name;
    }
    public void setName(String name) {
        this.name = name;
    }
    
}

package com.xujingyang.Exok;

/**
 * 生產商類
 * @author 徐景洋
 */
public class Producer implements Runnable {
    private Goods goods;

    public Goods getGoods() {
        return goods;
    }

    public void setGoods(Goods goods) {
        this.goods = goods;
    }

    @Override
    public void run() {
        for (int i = 0; i < 5; i++) {
            synchronized (goods) {
                if(goods.getNum()>0){
                    try {
                        goods.wait();//商品數量已經大於0啦,消費者要取貨咯,自己就開始等待咯
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
                
                if (i % 2 == 0) {
                    goods.setPinpai("哇哈哈");
                    try {
                        Thread.sleep(10);
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                    goods.setName("礦泉水");

                } else {
                    goods.setPinpai("旺仔");
                    try {
                        Thread.sleep(10);
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                    goods.setName("小饅頭");
                }
                goods.setNum((goods.getNum()+1));
                System.out.println("生產了" + goods.getPinpai() + goods.getName());
                goods.notify();//商品不夠啦,自己生產完,然后通知消費者取貨咯
            }
        }
    }

}

package com.xujingyang.Exok;

/**
 * 消費者類
 * @author 徐景洋
 */
public class Customer implements Runnable {

    private Goods goods;

    public Goods getGoods() {
        return goods;
    }

    public void setGoods(Goods goods) {
        this.goods = goods;
    }

    @Override
    public void run() {
        for (int i = 0; i < 5; i++) {
            synchronized (goods) {
                if(goods.getNum()<=0){
                    try {//如果商品生產的數量小於0,則開始等待.只有有貨才能購物嘛
                        goods.wait();
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
                
                try {
                    Thread.sleep(10);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                goods.setNum((goods.getNum()-1));
                System.out.println("取走了" + goods.getPinpai() + goods.getName());
                goods.notify();//取走之后通知生產商繼續生產商品(喚醒在對象鎖等待池中的線程繼續執行)
            }
        }
    }

}

package com.xujingyang.Exok;

/**
 * 測試類
 * @author 徐景洋
 */
public class Test {
    public static void main(String[] args) {
        Goods goods=new Goods();
        
        //生產者生產商品
        Producer p=new Producer();
        p.setGoods(goods);
        
        //消費者取走商品
        Customer c=new Customer();
        c.setGoods(goods);
        
        new Thread(p).start();
        new Thread(c).start();
    }
}

清晰明了不,嘿嘿