ArrayBlockingQueue是线程安全的有界阻塞队列，基于数组实现，使用ReentrantLock保证同步，创建时需指定容量且不可变，支持公平与非公平策略；提供add、offer、put等入队方法，其中put在队列满时阻塞，适合生产者；提供poll、take、peek等出队方法，其中take在队列空时阻塞，适合消费者；常用于生产者-消费者模型，如任务调度与线程池，需注意合理设置容量与处理中断异常。
在Java中，ArrayBlockingQueue 是一个线程安全的、基于数组实现的有界阻塞队列。它支持多线程环境下的生产者-消费者模式，常用于任务调度、线程池等场景。使用它时不需要手动加锁，内部已经通过 ReentrantLock 实现了同步控制。
创建 ArrayBlockingQueue
ArrayBlockingQueue 必须指定容量大小，且一旦创建后不能更改。构造函数需要传入一个整数表示队列的最大长度。
- Queue
queue = new ArrayBlockingQueue(10); // 容量为10的队列
还可以选择是否启用公平策略。默认是非公平的（性能更高），但可以设置为 true 来保证等待最久的线程优先获取锁。
- ArrayBlockingQueue
fairQueue = new ArrayBlockingQueue(5, true);
添加元素的方法
有几种方式可以向队列中添加元素，行为略有不同：
立即学习“Java免费学习笔记（深入）”；
-
add(E e)：成功返回 true，队列满时抛出
IllegalStateException - offer(E e)：成功返回 true，队列满时返回 false
- offer(E e, long timeout, TimeUnit unit)：尝试在指定时间内插入，超时返回 false
- put(E e)：阻塞直到有空间可用（适合生产者）
示例：
Shopxp网上购物系统
下载
Shopxp购物系统历经多年的考验，并在推出shopxp免费购物系统下载之后，收到用户反馈的各种安全、漏洞、BUG、使用问题进行多次修补，已经从成熟迈向经典，再好的系统也会有问题，在完善的系统也从在安全漏洞，该系统完全开源可编辑，当您下载这套商城系统之后，可以结合自身的技术情况，进行开发完善，当然您如果有更好的建议可从官方网站提交给我们。Shopxp网上购物系统完整可用，无任何收费项目。该系统经过
try {
queue.put("task1"); // 阻塞直到能放入
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
}
获取元素的方法
从队列取出元素也有多种方式：
- poll()：取出并移除队首元素，队列为空时返回 null
- poll(long timeout, TimeUnit unit)：等待指定时间尝试取元素，超时返回 null
- take()：阻塞直到有元素可用（适合消费者）
- peek()：查看队首元素但不移除，队列空时返回 null
示例：
try {
String task = queue.take(); // 阻塞直到拿到任务
System.out.println("处理任务: " + task);
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
}
实际应用场景：生产者-消费者模型
这是 ArrayBlockingQueue 最常见的用途。多个生产者线程生成数据放入队列，多个消费者线程从中取出处理。
简单示例：
// 共享队列 ArrayBlockingQueuebuffer = new ArrayBlockingQueue<>(5); // 生产者线程 Runnable producer = () -> { for (int i = 1; i <= 10; i++) { try { buffer.put("消息" + i); System.out.println("生产: 消息" + i); Thread.sleep(500); } catch (InterruptedException e) { Thread.currentThread().interrupt(); } } }; // 消费者线程 Runnable consumer = () -> { while (true) { try { String msg = buffer.take(); System.out.println("消费: " + msg); if (msg.equals("消息10")) break; // 结束条件 Thread.sleep(800); } catch (InterruptedException e) { Thread.currentThread().interrupt(); } } }; // 启动线程 new Thread(producer).start(); new Thread(consumer).start();
基本上就这些。ArrayBlockingQueue 使用简单，关键是理解其阻塞特性，在合适的场景下合理设置容量和超时时间，避免死锁或资源浪费。注意处理 InterruptedException，保持线程中断状态。不复杂但容易忽略细节。
