生产者消费者模式案例

该例子利用多线程实现生产者消费者模型。

两个线程：

• 生产者；
• 消费者。

实现的功能：

• 生产者生产满，通知消费者去消费；
• 仓库没有产品，通知生产者去生产。

为了使代码可读性强，清晰易懂，楼主建了四个Java类：

1.EventStorage：仓储模型，用于定义生产和消费的方法；

2.Producer：生产者；

3.Consumer：消费者；

4.TestThread：用于测试。

/**
 * 仓储模型
 */
public class EventStorage {
    
    //用于打印时间
    private List<Date> storage;
    
    //最大生产数量
    private int maxSize;
    
    public EventStorage() {
        
        maxSize = 10;
        storage = new LinkedList<Date>();
    }
    
    //模拟生产动作
    public synchronized void set() {
        while (storage.size() == maxSize) {
            try {
                wait();//如果生产满，通知生产者等待
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        
        storage.add(new Date());
        System.out.println("生产: "+ storage.size());
        notifyAll();//唤醒在等待操作资源的线程（队列）
    }
    
    //模拟消费动作
    public synchronized void get() {
        while (storage.size() == 0) {
            try {
                wait();//如果为空，通知消费者等待
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        
        System.out.println("剩余: "+ storage.size()+ ",Time: " +((LinkedList<?>)storage).poll());  
        notifyAll();//唤醒在等待操作资源的线程（队列）  
    }    
}

/**
 * 生产者
 * @author ycchia
 *
 */
public class Producer implements Runnable {
    
    //仓储模型
    private EventStorage storage;

    //构造函数
    public Producer(EventStorage storage) {
        this.storage = storage;
    }

    @Override
    public void run() {
        for (int i = 0; i < 100; i++) {
            //调用生产方法
            storage.set();
        }
    }
}

/**
 * 消费者
 * @author ycchia
 *
 */
public class Consumer implements Runnable {

    //仓储模型
    private EventStorage storage;
    
    //构造函数
    public Consumer(EventStorage storage) {
        this.storage = storage;
    }
    
    @Override
    public void run() {
        for (int i = 0; i < 100; i++) {
            //调用消费方法
            storage.get();
        }
    }
}

public class TestThread {

    public static void main(String[] args) {
        
        EventStorage storage = new EventStorage();
        Producer producer = new Producer(storage);
        //生产者线程
        Thread t1 = new Thread(producer);
        Consumer consumer = new Consumer(storage);
        //消费者线程
        Thread t2 = new Thread(consumer);

        //启动线程
        t2.start();
        t1.start();
    }
}

启动程序，console信息如下：

完美实现多线程同步。快去试一下吧！