java ConcurrentLinkedQueue是什么

ConcurrentLinkedQueue 是 Java 中基于 CAS 实现的无锁、线程安全、无界 FIFO 队列;插入在队尾、删除在队头,用 volatile head/tail 保证可见性,size() 非常量时间且不准确,应优先用 isEmpty(),迭代器提供弱一致性快照。

ConcurrentLinkedQueue 是 Java 并发包(java.util.concurrent)中一个线程安全、无界、基于链表的 FIFO 队列。

它是一个无锁的非阻塞队列

不依赖

synchronized 或 ReentrantLock,而是靠 CAS(Compare-And-Swap)原子操作实现线程安全。多个线程同时 offer(入队)或 poll(出队)时,不会互相阻塞,也不会因锁竞争导致上下文切换开销。

  • 插入总在队尾,删除总在队头,严格遵循先进先出
  • 内部用 volatile 修饰的 headtail 指针维护链表首尾,保证内存可见性
  • 节点是单向链表结构,每个 Node 包含 item(元素)和 next(后继指针)

它没有容量限制,但 size() 不是常量时间

理论上可无限增长(实际受限于堆内存),offer(e) 总是返回 true,不会失败或阻塞。

  • size() 需要遍历整个链表计数,且遍历时若其他线程修改队列,结果可能不准确
  • 所以生产环境避免在高频路径中频繁调用 size()
  • 判断空用 isEmpty(),它只检查 head.item 是否为 null,更快更可靠

它提供弱一致性的迭代器

调用 iterator() 得到的迭代器,反映的是创建那一刻的队列快照,遍历时即使其他线程增删元素,也不会抛 ConcurrentModificationException,也不会漏掉或重复遍历已存在的元素。

  • 适合“读多写少”或对实时一致性要求不苛刻的场景
  • 不适合需要强一致性遍历(比如做原子性批量处理)的逻辑

基本上就这些。它不是万能队列,但当你需要高吞吐、低延迟、纯内存、无锁并发的 FIFO 缓冲时,ConcurrentLinkedQueue 是非常自然的选择。