生產者消費者模式案例

該例子利用多線程實現生產者消費者模型。

兩個線程：

• 生產者；
• 消費者。

實現的功能：

• 生產者生產滿，通知消費者去消費；
• 倉庫沒有產品，通知生產者去生產。

為了使代碼可讀性強，清晰易懂，樓主建了四個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信息如下：

完美實現多線程同步。快去試一下吧！