package lly;

public class Box
{
    private int value;

    private boolean available = false;

    public synchronized int get()
    {
        while (available == false)
        {
            try
            {
                // 等待生产者写入数据
                wait();
            } catch (InterruptedException e)
            {
                // TODO: handle exception
                e.printStackTrace();
            }
        }
        available = false;
        // 通知生产者数据已经被取走，可以再次写入数据
        notifyAll();
        return value;
    }

    public synchronized void put(int value)
    {
        while (available == true)
        {
            try
            {
                // 等待消费者取走数据
                wait();
            } catch (InterruptedException e)
            {
                // TODO: handle exception
                e.printStackTrace();
            }
        }
        this.value = value;
        available = true;
        // 通知消费者可以来取数据
        notifyAll();
    }

}
package lly;

public class Consumer extends Thread
{
    private Box box;

    private String name;

    public Consumer(Box b, String n)
    {
        box = b;
        name = n;
    }

    public void run()
    {
        int value = 0;
        for (int i = 1; i < 6; i++)
        {

            value = box.get();
            System.out.println("Consumer " + name + " consumed: " + value);

            try
            {
                sleep((int) (Math.random() * 10000));
            } catch (InterruptedException e)
            {
                // TODO: handle exception
                e.printStackTrace();
            }
        }
    }

}
package lly;

public class Producer extends Thread
{
    private Box box;

    private String name;

    public Producer(Box b, String n)
    {
        box = b;
        name = n;
    }

    public void run()
    {
        for (int i = 1; i < 6; i++)
        {
            box.put(i);
            System.out.println("Producer " + name + " produced: " + i);

            try
            {
                sleep((int) (Math.random() * 10000));
            } catch (InterruptedException e)
            {
                // TODO: handle exception
                e.printStackTrace();
            }
        }
    }

}
package lly;

public class ProducerConsumer
{

    /**
     * @param args
     */
    public static void main(String[] args)
    {
        // TODO 自动生成方法存根
        Box box = new Box();
        Producer p = new Producer(box, "p");
        Consumer c = new Consumer(box, "c");

        p.start();
        c.start();

    }

}

评论