并发容器与队列——选型、弱一致迭代与 BlockingQueue 家族
你在大纲里已经列了 ConcurrentHashMap、ConcurrentLinkedQueue、BlockingQueue 等，但工程上更常见的问题是：
- 我该选哪一种？
- 迭代器为什么“看起来不一致”？
- 为什么会 OOM/卡死/延迟抖动？
本篇用“选型 + 坑点”的角度补齐。
1. 并发容器的一个核心语义：弱一致（weakly consistent）
很多并发容器的迭代器（iterator）是弱一致：
- 迭代期间允许并发修改
- 不抛
ConcurrentModificationException - 但你不能指望它是某个时间点的强一致快照
工程含义：
- 用并发容器做统计/遍历时，要接受“近似一致”，或自行做快照（拷贝/版本化）。
2. CopyOnWriteArrayList/Set：读多写少的利器
2.1 适用场景
- 读远多于写（配置、白名单、监听器列表）
- 允许写入成本高（写时复制）
2.2 关键特性
- 写操作会复制底层数组（写放大）
- 迭代器是快照语义：迭代看到的是创建迭代器时的数组
2.3 大坑
- 写频繁会非常慢 + 内存抖动大
- 元素很大、数组很大时复制成本极高
3. ConcurrentSkipListMap/Set：并发 + 有序
当你需要：
- 并发安全
- 并且需要有序遍历/范围查询（
subMap/headMap/tailMap）
优先考虑 SkipList。
取舍：
- 相比
ConcurrentHashMap，常数更大，纯 key->value 查询可能更慢 - 但它提供了“有序能力”，这是 CHM 做不到的
4. ConcurrentLinkedQueue：无锁队列（高并发下很香）
典型特点：
- 非阻塞（lock-free）
offer/poll使用 CAS
工程注意：
- 它是无界队列：如果生产者远快于消费者，会积压占内存
- 如果你需要“背压/阻塞”，直接用
BlockingQueue
5. BlockingQueue 家族：线程池与生产者-消费者的地基
5.1 ArrayBlockingQueue（有界、数组、单锁）
- 优点：强有界、内存可控
- 缺点：单锁竞争下吞吐可能受限
- 适用：更想要可控延迟/可控内存
5.2 LinkedBlockingQueue（可选有界、链表、双锁）
- 优点：put/take 分离，吞吐通常更好
- 缺点：节点对象分配更多；如果无界会 OOM
5.3 SynchronousQueue（零容量，直接移交）
- 适用：不想排队，想用“扩线程”应对突发（配合合理 max）
- 易错：max 过大 → 线程爆炸；max 太小 → 拒绝风暴
5.4 PriorityBlockingQueue（优先级，无界）
- 适用：任务有优先级
- 大坑：默认无界，仍要考虑内存风险
5.5 DelayQueue（延迟队列）
- 适用：定时任务、延迟重试、超时检查
- 关键点：元素必须实现
Delayed
5.6 LinkedTransferQueue（高吞吐移交队列）
- 特点：支持 transfer（生产者可以等待消费者接走）
- 在高并发场景中常被用于高吞吐任务移交
6. 选型建议（工程版）
- 你需要“有界 + 背压”：
ArrayBlockingQueue或LinkedBlockingQueue(cap) - 你需要“零排队、直接移交”：
SynchronousQueue - 你需要“定时/延迟”：
DelayQueue（或ScheduledThreadPoolExecutor） - 你需要“并发 + 有序”：
ConcurrentSkipListMap/Set - 你需要“读多写少的列表”：
CopyOnWriteArrayList/Set
7. 常见事故与排查方向
- OOM：
- 使用了无界队列（LinkedBlockingQueue 默认无界、PriorityBlockingQueue 无界）
- 消费端变慢导致积压
- 延迟抖动：
- 锁竞争（单锁队列、高竞争的 synchronized 容器）
- GC 压力（链表节点大量分配）
- “遍历不一致”误判为 bug：
- 弱一致迭代器的预期行为
8. 小结
并发容器不是“线程安全的集合”这么简单：
- 它们在一致性语义、性能、内存开销上都有明确取舍。
- 工程选型优先回答三件事：是否需要有界、是否需要阻塞、是否需要有序。
面试题 / Checklist
- 什么是弱一致迭代器？为什么并发容器通常不抛 CME？
CopyOnWriteArrayList的写放大体现在哪里？适合/不适合什么场景？ConcurrentSkipListMap的核心价值是什么？相比 CHM 的取舍点？ConcurrentLinkedQueue为什么适合高并发？它的“无界”风险如何治理？ArrayBlockingQueuevsLinkedBlockingQueue的锁模型差异与适用场景？SynchronousQueue的语义是什么？它对线程池行为有什么影响？
相关推荐
2025-12-12 10:07
AQS - AbstractQueuedSynchronizer
AQS - Java 8这是一个非常好的课题。AQS (AbstractQueuedSynchronizer) 是 Java 并发包 (java.util.concurrent) 中许多同步组件（如 ReentrantLock, CountDownLatch, Semaphore）的基石。理解了它，就理解了 Java 并发的半壁江山。 我将生成两张 Excalidraw 风格的图片来辅助讲解： AQS 宏观内部结构图：展示 State、持有线程以及 CLH 等待队列的整体关系。 AQS 核心流程与状态转换图：展示一个线程尝试获取锁失败后，如何进入队列、改变前驱节点状态以及最终被唤醒的动态过程。 AQS 宏观内部结构图这一张图展示了 AQS 是如何通过一个共享资源状态 (state) 和一个先进先出的等待队列 (CLH Queue) 来管理线程的。 AQS 核心流程与状态转换图 (Acquire Flow)这一张图聚焦于动态过程。当一个线程尝试去 “acquire”（获取锁）时，如果成功了会怎样，如果失败了，它在队列中会经历哪些关键状态的变迁。 图文详解 AQS 原理AQS 的...
2025-12-04 21:00
JUC并发编程
JUC 包是 Java 并发编程的基石，包含了线程池、锁、原子操作、并发集合等核心组件。 本站 JUC 导航建议阅读顺序：基础（JMM/中断/等待唤醒）→ AQS/锁 → 同步器/容器队列 → 线程池与调参 → CompletableFuture 工程化。 线程与中断：interrupt 语义、阻塞点表现、优雅取消模板 等待与唤醒机制：wait/notify、Condition、LockSupport 对照 原子类与CAS：CAS/ABA、LongAdder、FieldUpdater、volatile 落地与常见坑 AQS：AQS 原理与 JDK 17 重构要点 Java锁：synchronized 锁升级、显式锁、读写锁、StampedLock、分布式锁视角 同步器：CountDownLatch / CyclicBarrier / Semaphore / Phaser / Exchanger 选型与坑 并发容器与队列：CopyOnWrite、SkipList、Blocking...
2025-12-08 20:29
Java锁
原理学习Java 中的锁机制经历了从重型到轻量，从单一到多元的发展历程。要深入理解它们，不能只背诵概念，必须结合 JVM 内存模型 (JMM)、对象头 (Mark Word) 以及 AQS (AbstractQueuedSynchronizer) 的底层原理。 以下是对 Java 各类锁的深度解析，涵盖 JVM 层面的锁优化、JUC 显式锁以及分布式环境下的锁策略。 一、 宏观分类：锁的特性视角在深入具体实现之前，我们需要建立一个清晰的分类体系。这些术语描述的是锁的特性或设计思想，而非具体的类。 锁分类 描述 代表实现 适用场景 乐观锁 假设没有冲突，操作时检测数据是否被修改 (CAS)。 AtomicInteger, 数据库版本号 读多写少，竞争不激烈 悲观锁 假设总有冲突，操作前先锁定。 synchronized, ReentrantLock 写多读少，竞争激烈 可重入锁 允许同一个线程多次获取同一把锁，防止死锁。 synchronized, ReentrantLock 递归调用，父子类方法调用 公平锁 严格按照请求顺序获取锁 (FIFO)。 Re...
2025-12-12 13:53
线程池
学习大纲要想深入理解 JUC (Java Util Concurrent) 的线程池实现，不能只看 ThreadPoolExecutor 一个类，而应该顺藤摸瓜，从接口定义、核心实现、辅助组件三个维度入手。 以下是按“阅读优先级”排序的源码研读路径： 第一阶段：核心骨架（必看）这是线程池的灵魂，90% 的面试题和生产环境故障都源于对这个类的误解。 java.util.concurrent.ThreadPoolExecutor (核心) 地位：绝对的核心。 看什么： ctl 变量：高 3 位存状态，低 29 位存线程数。这是位运算设计的典范。 execute(Runnable command)：入口方法，蕴含了“三级缓冲”逻辑（核心线程 -> 队列 -> 最大线程 -> 拒绝）。 addWorker(Runnable firstTask, boolean core)：如何创建一个线程并启动它。 内部类 Worker：重点！它继承了 AQS。为什么要继承 AQS？为了实现独占锁，判断线程是否空闲（中断时使用）。 runWorker(Worker w)：线程启动后...
2025-12-04 20:54
Spring Cloud
Spring Cloud 是一个广泛用于构建微服务架构的框架集合，涵盖了服务发现、配置管理、负载均衡、熔断器、API 网关、消息总线等多个方面。以下是一个系统的 Spring Cloud 学习路线，适合初学者循序渐进地掌握其核心内容。 1. 基础准备在学习 Spring Cloud 之前，需要打好以下基础： Java 基础：熟悉 Java 编程语言，包括面向对象编程、集合框架、异常处理等。 Spring Boot：Spring Cloud 基于 Spring Boot 构建，需掌握 Spring Boot 的核心概念，如自动配置、依赖注入、RESTful API 开发、Spring Data JPA 等。 微服务架构：了解微服务的基本概念、优缺点，以及与传统单体应用的区别。 HTTP 和 REST：掌握 HTTP 协议和 RESTful 服务设计原则。 Maven 或 Gradle：熟悉项目构建工具，学会管理依赖和构建项目。 2. Spring Cloud 核心组件学习Spring Cloud 由多个子项目组成，每个子项目解决微服务架构中的特定问题。以下是核心组件及其推荐...
2025-12-03 22:37
Spring 过滤器
Filter 和 InterceptorFilter 过滤器 Servlet 容器维度的，拦截 Servlet 的请求。 通过 Filter 接口实现的 Servlet 容器： Tomcat、Jetty。遵循 Java Servlet 规范，通常包括 HTTP 服务器，处理 web 请求和响应。 Interceptor 拦截器 Spring 容器维度的，对 Spring MVC 的请求进行拦截。 通过实现 HandlerInterceptor 接口实现的，并通过 Spring 的配置进行注册。 PS：Spring 框架嵌入到 Servlet 容器中，利用 spring 容器管理应用程序中的其他组件: Spring Beans： 在 Spring 框架中，你可以定义和配置各种 Bean，包括业务逻辑组件、数据访问组件、服务等。这些 Bean 的生命周期、依赖关系等都由 Spring 容器管理。 Service 层和业务逻辑： 你可以使用 Spring 来管理业务逻辑层的组件，使其成为 Spring 容器管理的 Bean。这些业务逻辑组件通常包括服务层的实现，处理业务逻辑、事务...