如何在Java中实现BlockingQueue

在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，我们可以很方便地实现生产者-消费者模式，而不需要手动编写线程同步的逻辑，使得代码更加简洁和易于维护。