生產(chǎn)者和消費(fèi)者是操作系統(tǒng)中的一個經(jīng)典問題，這個問題是在講“進(jìn)程同步”時的一個例子，下面我就用Java語言中的notify和wait關(guān)鍵字實(shí)現(xiàn)這個算法。

生產(chǎn)者

/**
 * Description: 生產(chǎn)者.
 *
 * @author: crane-yuan
 */
public class Producer extends Thread
{
    static final int MAXQUEUE = 10;
    private Vector   messages = new Vector();
    /**
     * Description:
     *
     * @see java.lang.Thread#run()
     */
    @Override
    public void run() {
        try {
            while (true) {
                putMessage();
                sleep(1500);
            }
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
    private synchronized void putMessage() throws InterruptedException {
        while (messages.size() == MAXQUEUE) {
            wait();
        }
        messages.add(new Date().toLocaleString());
        System.out.println("put message...");
        notify();
    }
    //Called by Consumer
    public synchronized String getMessage() throws InterruptedException {
        notify();
        while (messages.size() == 0) {
            wait();
        }
        String message = (String) messages.firstElement();
        messages.remove(message);
        return message;
    }
}

消費(fèi)者

/**
 * Description: 消費(fèi)者.
 *
 * @author: crane-yuan
 */
public class Consumer extends Thread
{
    Producer producer;
    Consumer(Producer p) {
        producer = p;
    }

    /**
     * Description:
     *
     * @see java.lang.Thread#run()
     */
    @Override
    public void run() {
        try {
            while (true) {
                String message = producer.getMessage();
                System.out.println("Got message: "+message);
                sleep(2000);
            }
        } catch(InterruptedException e) {
            e.printStackTrace();
        }
    }

    public static void main(String[] args) {
        Producer producer = new Producer();
        producer.start();
        new Consumer(producer).start();
    }
}

結(jié)果

put message...
Got message: 2016-11-5 17:06:28
put message...
Got message: 2016-11-5 17:06:30
put message...
Got message: 2016-11-5 17:06:32
put message...
put message...
Got message: 2016-11-5 17:06:33
put message...
Got message: 2016-11-5 17:06:35
put message...
Got message: 2016-11-5 17:06:36
put message...
put message...
Got message: 2016-11-5 17:06:38