怎么用Java实现阻塞队列

可以使用Java中的BlockingQueue接口来实现阻塞队列。

首先，需要导入java.util.concurrent包，因为BlockingQueue接口是该包中的一部分。

然后，可以选择合适的阻塞队列实现类。常见的阻塞队列实现类有ArrayBlockingQueue、LinkedBlockingQueue和SynchronousQueue等。

以下是一个使用ArrayBlockingQueue实现阻塞队列的示例代码：

import java.util.concurrent.ArrayBlockingQueue; import java.util.concurrent.BlockingQueue; public class BlockingQueueExample { public static void main(String[] args) { // 创建一个容量为10的阻塞队列 BlockingQueue<Integer> queue = new ArrayBlockingQueue<>(10); // 创建一个生产者线程 Thread producerThread = new Thread(() -> { try { // 生产1到10的数字，并将其放入队列 for (int i = 1; i <= 10; i++) { queue.put(i); System.out.println("Produced: " + i); Thread.sleep(1000); } } catch (InterruptedException e) { e.printStackTrace(); } }); // 创建一个消费者线程 Thread consumerThread = new Thread(() -> { try { // 从队列中取出数字并消费 while (true) { int num = queue.take(); System.out.println("Consumed: " + num); Thread.sleep(2000); } } catch (InterruptedException e) { e.printStackTrace(); } }); // 启动生产者和消费者线程 producerThread.start(); consumerThread.start(); } } 

在以上示例代码中，创建了一个容量为10的ArrayBlockingQueue对象，然后创建了一个生产者线程和一个消费者线程。生产者线程会不断生产数字并放入队列中，消费者线程会从队列中取出数字并消费。如果队列已满，生产者线程会被阻塞直到有空间可用；如果队列为空，消费者线程会被阻塞直到队列中有元素可取。