/**
 * Producer產(chǎn)生的饅頭類
 * @author itmyhome
 *
 */
public class Mantou {
    private String mantou;
    public Mantou(String mantou) {
        this.mantou = mantou;
    }
    public String getMantou() {
        return mantou;
    }
    public void setMantou(String mantou) {
        this.mantou = mantou;
    }
}

import java.util.concurrent.BlockingQueue;
public class Producer implements Runnable {
    BlockingQueue<Mantou> queue;
    public Producer(BlockingQueue<Mantou> queue) {
        this.queue = queue;
    }
    @Override
    public void run() {
        // 生產(chǎn)饅頭
        for (int i = 0; i < 100; i++) {
            Mantou mt = new Mantou("" + i);
            try {
                Thread.sleep(100);
                queue.put(mt);
                System.out.println("生產(chǎn)饅頭: " + mt.getMantou());
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        // 添加退出消息
        Mantou msg = new Mantou("exit");
        try {
            queue.put(msg);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

import java.util.concurrent.BlockingQueue;
public class Consumer implements Runnable {
    BlockingQueue<Mantou> queue;
    public Consumer(BlockingQueue<Mantou> queue) {
        this.queue = queue;
    }
    @Override
    public void run() {
        try {
            Mantou mantou;
            // 獲取并處理消息直到接收到“exit”消息
            while (!(mantou = queue.take()).getMantou().equals("exit")) {
                Thread.sleep(100);
                System.out.println("消費(fèi)饅頭： " + mantou.getMantou());
            }
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;
/**
 * @author itmyhome
 *
 */
public class ProducerConsumerService {
    public static void main(String[] args) {
        // 創(chuàng)建大小為10的 BlockingQueue
        BlockingQueue<Mantou> queue = new ArrayBlockingQueue<Mantou>(10);
        Producer producer = new Producer(queue);
        Consumer consumer = new Consumer(queue);
        // 開啟 producer線程向隊(duì)列中生產(chǎn)消息
        new Thread(producer).start();
        //開啟 consumer線程 中隊(duì)列中消費(fèi)消息
        new Thread(consumer).start();
        System.out.println("Producer and Consumer has been started");
    }
}