JavaBlockingQueue实现生产者消费者模式全解析

import java.util.concurrent.BlockingQueue;
import java.util.concurrent.ArrayBlockingQueue;

// 共享数据
class Data {
    private final int value;

    public Data(int value) {
        this.value = value;
    }

    @Override
    public String toString() {
        return "Data{" + "value=" + value + '}';
    }
}

// 生产者
class Producer implements Runnable {
    private final BlockingQueue<data> queue;

    public Producer(BlockingQueue<data> queue) {
        this.queue = queue;
    }

    @Override
    public void run() {
        try {
            for (int i = 1; i  queue;

    public Consumer(BlockingQueue<data> queue) {
        this.queue = queue;
    }

    @Override
    public void run() {
        try {
            while (true) {
                Data data = queue.take(); // 阻塞取出
                System.out.println("消费者消费: " + data);
                Thread.sleep(1000); // 消费较慢
            }
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        }
    }
}

// 主程序
public class ProducerConsumerExample {
    public static void main(String[] args) {
        // 创建容量为3的阻塞队列
        BlockingQueue<data> queue = new ArrayBlockingQueue(3);

        // 启动生产者和消费者线程
        Thread producerThread = new Thread(new Producer(queue));
        Thread consumerThread = new Thread(new Consumer(queue));

        producerThread.start();
        consumerThread.start();

        // 可以设置运行时间后中断
        try {
            Thread.sleep(6000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

        producerThread.interrupt();
        consumerThread.interrupt();
    }
}
</data></data></data></data>