/**
 * 消息隊列中存放的消息類
 */
final public class Message {
    private int id;
    private int value;
    public Message(int id,int value){
        this.id = id;
        this.value = value;
    }
    public int getId() {
        return id;
    }
    public int getValue() {
        return value;
    }
}

import lombok.extern.slf4j.Slf4j;
import java.util.LinkedList;
/**
 * 實現(xiàn)一個阻塞隊列（消息隊列），實現(xiàn)java線程間通信
 */
@Slf4j
public class MessageQueue {
    // 消息隊列的容量
    private int capacity;
    // 消息隊列
    LinkedList<Message> messageQueue = new LinkedList<>();
    // 設(shè)置消息隊列的容量
    public MessageQueue(int capacity){
        this.capacity = capacity;
    }
    // 從消息隊列中取消息
    public Message take(){
        synchronized (messageQueue){
            // 如果消息隊列為空
            while (messageQueue.isEmpty()){
                try {
                    log.debug("隊列為空, 消費者線程等待");
                    messageQueue.wait();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
            Message message = messageQueue.removeFirst();
            log.debug("已消費消息 {}", message);
            // 走到這，說明消息隊列不為null
            messageQueue.notifyAll();
            return message;
        }
    }
    // 往消息隊列中放消息
    public void put(Message message){
        synchronized (messageQueue){
            // 如果消息隊列已滿
            while (messageQueue.size()==capacity){
                try {
                    log.debug("隊列已滿, 生產(chǎn)者線程等待");
                    messageQueue.wait();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
            messageQueue.addLast(message);
            log.debug("已生產(chǎn)消息 {}", message);
            // 走到這，說明消息隊列不滿
            messageQueue.notifyAll();
        }
    }
}

public class Main {
    public static void main(String[] args) {
        MessageQueue queue = new MessageQueue(2);
        for(int i=0;i<3;i++){
            int id = i;
            new Thread(()->{
                queue.put(new Message(id,id));
            },"生產(chǎn)者").start();
        }
        new Thread(()->{
            while (true){
                try {
                    Thread.sleep(1000);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                Message message = queue.take();
            }
        },"消費者").start();
    }
}