阅读量:0
在Java中，可以使用java.util.concurrent包中的BlockingQueue接口来实现阻塞队列。BlockingQueue接口提供了put()和take()方法用于插入和获取元素，当队列已满或为空时，put()和take()方法会阻塞当前线程，直到队列有空间或有元素可获取。
以下是一个简单的示例，演示如何使用BlockingQueue实现一个生产者-消费者模式：
import java.util.concurrent.ArrayBlockingQueue; import java.util.concurrent.BlockingQueue; public class ProducerConsumerExample { private static final int CAPACITY = 5; private static BlockingQueue<Integer> queue = new ArrayBlockingQueue<>(CAPACITY); public static void main(String[] args) { Thread producer = new Thread(new Producer()); Thread consumer = new Thread(new Consumer()); producer.start(); consumer.start(); } static class Producer implements Runnable { public void run() { try { for (int i = 0; i < 10; i++) { queue.put(i); System.out.println("Produced: " + i); } } catch (InterruptedException e) { e.printStackTrace(); } } } static class Consumer implements Runnable { public void run() { try { for (int i = 0; i < 10; i++) { int value = queue.take(); System.out.println("Consumed: " + value); } } catch (InterruptedException e) { e.printStackTrace(); } } } } 在这个例子中，我们创建了一个ArrayBlockingQueue作为阻塞队列，然后分别创建了生产者和消费者线程。生产者线程会往队列中插入元素，消费者线程会从队列中获取元素。生产者和消费者线程会交替执行，直到队列中的元素全部被消费完。
通过使用BlockingQueue，我们可以很方便地实现生产者-消费者模式，而不需要手动编写线程同步的逻辑，使得代码更加简洁和易于维护。
