concurrentlinkedqueue 可直接实现线程安全的无界任务缓冲区，因其基于链表和cas的无锁fifo设计，支持高并发生产消费、容量不受限、弱一致性迭代器；但禁止null元素，size()不准确，无阻塞语义需配合分发线程与线程池使用。
直接用 ConcurrentLinkedQueue 就能实现线程安全的无界任务缓冲区，它天然支持高并发、非阻塞、FIFO，且无需额外加锁。
为什么选 ConcurrentLinkedQueue
它是 Java 并发包中专为无界、高性能场景设计的队列：
- 基于链表 + CAS 实现，完全无锁，避免线程阻塞
- 允许多个生产者线程同时
offer()，多个消费者线程同时poll()，互不干扰 - 容量不受限（仅受内存约束），适合突发流量或异步任务积压场景
- 不抛
ConcurrentModificationException，迭代器弱一致性，适合只读遍历监控（如统计、日志）
基础用法：创建与任务入出队
声明队列并添加任务（例如 Runnable 或自定义任务对象）：
ConcurrentLinkedQueue<runnable> taskQueue = new ConcurrentLinkedQueue();
// 生产者线程：提交任务
taskQueue.offer(() -> System.out.println("执行任务"));
// 消费者线程：取出并执行
Runnable task = taskQueue.poll();
if (task != null) {
task.run();
}</runnable>
注意：offer() 总返回 true（无界队列不会拒绝入队）；poll() 返回 null 表示当前为空，需判空处理。
关键注意事项
几个容易踩坑但文档常忽略的点：
-
不允许 null 元素：插入
null会直接抛NullPointerException，建议任务封装前做非空校验 -
size() 是近似值：多线程下调用
taskQueue.size()可能滞后或不准，不能用于控制逻辑（比如“等队列空了再关闭”）；可用isEmpty()做快速空判断 -
不保证强一致性视图：一个线程刚
offer()，另一个线程立刻peek()可能还看不到——这是弱一致性设计使然，属于正常行为 -
无阻塞语义：如果消费者想“等任务来再处理”，不能靠
poll()循环空转，应配合Thread.sleep()或改用BlockingQueue（如LinkedBlockingQueue）
搭配线程池使用更稳妥
单独用队列只是缓冲，真正执行还需线程调度。推荐与 ThreadPoolExecutor 结合：
ConcurrentLinkedQueue<runnable> queue = new ConcurrentLinkedQueue();
ThreadPoolExecutor executor = new ThreadPoolExecutor(
2, 4, 60L, TimeUnit.SECONDS,
new SynchronousQueue(), // 注意：这里不用 ConcurrentLinkedQueue 作工作队列
r -> new Thread(r, "task-worker-%d")
);
// 自定义提交逻辑：先入缓冲队列，再由专用分发线程触发执行
new Thread(() -> {
while (!Thread.currentThread().isInterrupted()) {
Runnable task = queue.poll();
if (task != null) executor.execute(task);
else Thread.sleep(10); // 避免忙等
}
}).start();</runnable>
说明：虽然 ConcurrentLinkedQueue 本身线程安全，但 ThreadPoolExecutor 的标准构造函数不接受它作为工作队列（因缺少阻塞能力），所以需外置分发逻辑，这样既保留无界缓冲优势，又复用线程池的管理能力。
Java免费学习笔记：立即使用
解锁 Java 大师之旅：从入门到精通的终极指南
