线程中消费者生产者的实例代码(synchronized关键字)

http://www.cnblogs.com/DreamDrive/p/6204665.html  这个是用Lock类实现的.

场景:

厨师类:

import java.util.List;
import java.util.Random;
import java.util.concurrent.TimeUnit;

public class Cook implements Runnable {

    private List<Food> foods;
    private static int num = 1;
    private static final int MAXSIZE = 1;

    public List<Food> getFoods() {
        return foods;
    }

    public void setFoods(List<Food> foods) {
        this.foods = foods;
    }

    public Cook(List<Food> foods) {
        this.foods = foods;
    }

    public Cook() {
    }

    public void produce() {
        while (true) {
            synchronized (SaleWindow.class) {
                if (foods.size() < MAXSIZE) {//卖饭的桌子上饭总有 一定的容量限制.
                    Food food = new Food((num++) + "");
                    foods.add(food);
                    System.out.println(Thread.currentThread().getName()
                            + " ：做好 " + food.getId() + " 号饭了");
                    Random ran = new Random();
                    int i = ran.nextInt(300);
                    try {
                        TimeUnit.MILLISECONDS.sleep(i);
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                    
                    //SaleWindow.class.notify();
                    SaleWindow.class.notifyAll();
                } else {
                    System.out.println(Thread.currentThread().getName()
                            + " :桌子放满了。窗口赶紧卖，我休息了。。。");

                    try {
                        SaleWindow.class.wait();
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
            }
        }
    }

    @Override
    public void run() {
        produce();
    }
}

 食物类:

public class Food {

    private String id;

    
    public Food(String id) {
        this.id = id;
    }

    public String getId() {
        return id;
    }

    public void setId(String id) {
        this.id = id;
    }
    
    
}

 卖饭窗口类:

import java.util.List;
import java.util.Random;
import java.util.concurrent.TimeUnit;

public class SaleWindow implements Runnable {

    private List<Food> foods;

    public List<Food> getFoods() {
        return foods;
    }

    public void setFoods(List<Food> foods) {
        this.foods = foods;
    }

    public SaleWindow(List<Food> foods) {
        this.foods = foods;
    }

    public SaleWindow() {
    }

    public  void sale() {
        while (true) {
            synchronized (SaleWindow.class) {
                if (foods.size() > 0) {
                    try {
                        Food food = foods.get(0);
                        System.out.println(Thread.currentThread().getName()
                                + ": 卖出了 " + food.getId() + " 号饭...");
                        Random ran = new Random();
                        int i = ran.nextInt(300);

                        TimeUnit.MILLISECONDS.sleep(i);
                        foods.remove(0);
                        //SaleWindow.class.notify();//随机唤醒一条等待的线程
                        SaleWindow.class.notifyAll();//唤醒所有等待的线程
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }else{
                    System.out.println(Thread.currentThread().getName()+":饭买完了。厨师赶紧做，我休息了。。。");
                    try {
                        SaleWindow.class.wait();
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                    
                }
            }
        }
    }

    @Override
    public void run() {
        sale();
    }

}

 测试类:

import java.util.ArrayList;
import java.util.List;

public class Test {

    public static void main(String[] args) {

        List<Food> foods = new ArrayList<Food>();
        for (int i = 0; i < 4; i++) {//4个厨师 生产
            new Thread(new Cook(foods),"Cook"+(i+1)).start();
        }
        for (int i = 0; i < 3; i++) {//3个窗口 消费
            new Thread(new SaleWindow(foods),"sale"+(i+1)).start();
        }
    }
}