【javaEE】多线程初阶（Part6 阻塞队列）

在Java中，BlockingQueue是一个线程安全的队列，在队列为空的时候进行出队操作会阻塞线程，直到队列中有元素可供消费。同样，在队列满的时候进行入队操作也会阻塞线程，直到队列中有空间可供存放元素。

以下是使用BlockingQueue的一个简单例子：

import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;
 
public class BlockingQueueExample {
    public static void main(String[] args) {
        BlockingQueue<Integer> queue = new LinkedBlockingQueue<>(3); // 创建容量为3的阻塞队列
 
        // 生产者线程
        Runnable producer = () -> {
            try {
                for (int i = 0; i < 5; i++) {
                    queue.put(i); // 如果队列满了，这里会阻塞
                    System.out.println("Produced: " + i);
                    Thread.sleep(1000); // 生产间隔1秒
                }
            } catch (InterruptedException e) {
                Thread.currentThread().interrupt();
            }
        };
 
        // 消费者线程
        Runnable consumer = () -> {
            try {
                while (true) {
                    int item = queue.take(); // 如果队列为空，这里会阻塞
                    System.out.println("Consumed: " + item);
                    Thread.sleep(1000); // 消费间隔1秒
                }
            } catch (InterruptedException e) {
                Thread.currentThread().interrupt();
            }
        };
 
        Thread producerThread = new Thread(producer);
        Thread consumerThread = new Thread(consumer);
 
        producerThread.start();
        consumerThread.start();
    }
}

在这个例子中，我们创建了一个容量为3的LinkedBlockingQueue。然后，我们启动了一个生产者线程，该线程将数字放入队列中，并且每隔1秒钟放入一个数字。同时，我们启动了一个消费者线程，该线程会从队列中取出数字并打印，并且每隔1秒钟消费一个数字。如果队列为空或者满了，对应的生产者或消费者线程会阻塞，直到队列中有可供操作的元素或空间。