ArrayBlockingQueue通过固定容量间接防内存溢出，需合理设容量、用offer()替代put()、监控水位并注意对象引用管理。
ArrayBlockingQueue 本身不直接控制内存大小，它通过固定容量限制元素数量来间接防止内存溢出。关键在于合理设置容量，并配合生产者-消费者模式避免堆积。
明确容量上限，避免无界增长
ArrayBlockingQueue 是有界队列，构造时必须指定容量（int capacity）。这个容量决定了队列最多容纳多少个元素，而非字节大小。因此需根据单个元素的平均内存占用预估合理容量。
- 例如：若每个任务对象约占用 2KB，系统可接受最大堆内队列占用 10MB，则容量 ≈ 10 × 1024 / 2 ≈ 5120
- 创建时写法：new ArrayBlockingQueue<Task>(5120)
- 容量设得过大可能延迟 OOM；过小则频繁拒绝任务，需结合吞吐与容错权衡
配合 offer() 和 poll() 控制入队行为
不要用 put()（会阻塞直到有空位），改用 offer(E e) 或 offer(E e, long timeout, TimeUnit unit)，主动处理失败场景。
deep-java-review
下载
Java项目代码review工具。分析Git变更+完整调用链路上下文，推断业务需求，进行多维度评分和分类汇总，生成完整PRD文档。包含细粒度Java代码审查清单（Null安全、异常处理、Streams、并发、equals/hashCode、资源管理、API设计、性能、MyBatis/ORM、事务边界、SQL/DD...
- offer() 返回 false 表示队列已满，此时可记录日志、降级处理（如丢弃、告警、写入磁盘或外部消息队列）
- 避免在高负载下持续调用 put() 导致线程挂起，进而引发线程耗尽或响应延迟
- 示例：if (!queue.offer(task)) { log.warn("Queue full, dropping task"); }
监控实际使用水位，动态干预
利用 size() 和 remainingCapacity() 实时观察队列压力，当使用率长期超过 80%，说明容量偏小或消费滞后。
立即学习“Java免费学习笔记（深入）”；
- 定期采样：int usage = queue.size() * 100 / queue.capacity();
- 结合 Metrics（如 Micrometer）暴露队列长度指标，接入 Prometheus 告警
- 极端情况下可触发熔断（如暂停接收新任务）或扩容（仅限多实例场景，ArrayBlockingQueue 本身不可扩容）
注意对象引用与 GC 友好设计
队列满不是唯一风险点——即使容量合理，若元素持有大对象或未及时释放引用，仍会导致堆内存持续增长。
- 确保队列中对象不含长生命周期引用（如静态缓存、未关闭的流）
- 消费端处理完后尽快让对象脱离作用域，便于 GC 回收
- 必要时使用弱引用包装（如 WeakReference<Task>），但需谨慎评估业务语义是否允许被回收
