arrayblockingqueue是java中基于数组实现的有界阻塞队列，1. 初始化需指定固定容量，不可变；2. 使用put()/take()实现线程安全的阻塞通信；3. 可选公平策略控制线程等待顺序；4. 支持offer/poll等非阻塞操作提升灵活性；5. 需合理设置容量并处理中断异常。
在Java中，ArrayBlockingQueue 是一个基于数组实现的有界阻塞队列，常用于多线程环境下的生产者-消费者模型。它实现了 BlockingQueue 接口，具有线程安全、容量固定、支持阻塞插入和移除操作等特点。合理使用 ArrayBlockingQueue 能有效控制资源占用，避免内存溢出。
创建有界队列并设置容量
ArrayBlockingQueue 必须在初始化时指定容量大小，且不能为 null。一旦创建，其容量不可更改。
示例代码：
ArrayBlockingQueue<String> queue = new ArrayBlockingQueue<>(10); // 容量为10
如果尝试添加元素超过容量，put() 方法会阻塞，add() 方法则抛出异常。建议根据系统负载和资源情况合理设置上限，防止生产速度远超消费速度导致堆积。
使用 put() 和 take() 实现线程安全通信
在生产者-消费者场景中，put() 和 take() 是最常用的阻塞方法。
立即学习“Java免费学习笔记（深入）”；
- put(E e)：将元素插入队列，如果队列满，则当前线程阻塞直到有空间。
- take()：从队列头部取出元素，如果队列为空，则阻塞等待直到有元素可用。
// 生产者线程
new Thread(() -> {
try {
queue.put("data-" + System.currentTimeMillis());
System.out.println("生产: data");
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
}
}).start();
// 消费者线程
new Thread(() -> {
try {
String data = queue.take();
System.out.println("消费: " + data);
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
}
}).start();
这两个方法自动处理线程同步，无需额外加锁。
选择合适的构造参数：公平性设置
ArrayBlockingQueue 提供带布尔参数的构造函数，用于设置是否启用公平策略。
new ArrayBlockingQueue(10, true); 启用公平模式，线程按等待顺序获取锁，减少饥饿现象，但性能略低。默认为非公平模式，效率更高，但可能造成某些线程长期等待。
若系统对响应时间要求高，可接受轻微不公，使用非公平模式；若需保证每个生产者或消费者线程都能及时执行，建议开启公平性。
检查与非阻塞操作技巧
除了阻塞方法，还可以使用非阻塞或带超时的操作来提升灵活性。
- offer(E e)：插入元素，成功返回 true，队列满则立即返回 false。
- offer(E e, long timeout, TimeUnit unit)：尝试在指定时间内插入，超时返回 false。
- poll(long timeout, TimeUnit unit)：尝试在超时内取出元素，否则返回 null。
- peek()：获取但不移除头元素，队列为空返回 null。
这些方法适用于需要快速失败或限时等待的场景，比如实时性要求高的任务调度。
基本上就这些。ArrayBlockingQueue 使用简单，关键在于理解其阻塞机制和容量限制，在实际开发中结合业务需求选择合适的方法调用方式。注意处理 InterruptedException，并及时中断线程状态，确保程序健壮性。
