ArrayBlockingQueue是BlockingQueue接口的一个实现类之一

这个属于基础性问题，老规矩，我们将从使用场景和代码示例来进行讲解

来，思考片刻，给出你的答案

1，使用场景

1. 实现：基于数组实现的有界阻塞队列，构造时需要指定容量大小，无法动态扩容。
2. 场景：适用于固定大小的生产者-消费者模型，特别适合内存有限并且需要防止队列无限增长的场景。

2，来，上代码

import java.util.concurrent.ArrayBlockingQueue;public class ArrayBlockingQueueExample {static final int QUEUE_CAPACITY = 10;static final BlockingQueue<String> queue = new ArrayBlockingQueue<>(QUEUE_CAPACITY);public static void main(String[] args) throws InterruptedException {Thread producer = new Thread(() -> {try {for (int i = 0; i < 20; i++) {String item = "Item " + i;queue.put(item); // 如果队列满了，生产者会被阻塞System.out.println("Produced: " + item);}} catch (InterruptedException e) {e.printStackTrace();}});Thread consumer = new Thread(() -> {try {while (true) {String item = queue.take(); // 如果队列空了，消费者会被阻塞System.out.println("Consumed: " + item);}} catch (InterruptedException e) {e.printStackTrace();}});producer.start();consumer.start();// 等待producer完成producer.join();// 然后中断消费者consumer.interrupt();}
}

想提高面试准备效率！欢迎来加入我的星球！承诺三天内不满意，直接免费退出！