上一篇【第82篇】ChannelOutboundBuffer源码深度解析——Netty写缓冲区的秘密下一篇【第84篇】Netty Channel注册与Selector源码解析一、为什么不用BlockingQueue队列锁性能LinkedBlockingQueueReentrantLock一般MpscArrayQueue无锁(CAS)高Mpsc Multiple Producer, Single Consumer多生产者单消费者EventLoop是单消费者单线程消费多个Handler可以提交任务多生产者二、JCTools MpscQueue// Netty使用JCTools的MpscQueue// SingleThreadEventExecutor中的任务队列QueueRunnabletaskQueue;// PlatformDependent判断使用哪种if(PlatformDependent.hasUnsafe()){taskQueuenewMpscChunkedArrayQueue(maxPendingTasks);}else{taskQueuenewMpscGrowableArrayQueue(maxPendingTasks);}三、CAS无锁入队// MpscArrayQueue.offer()简化版// 多个生产者用CAS竞争入队位置publicbooleanoffer(Ee){longcurrentProducerIndexlvProducerIndex();// 读volatilelongnextProducerIndexcurrentProducerIndex1;// CAS竞争下一个槽位while(!casProducerIndex(currentProducerIndex,nextProducerIndex)){currentProducerIndexlvProducerIndex();nextProducerIndexcurrentProducerIndex1;}// 写入数据soElement(buffer,offset(nextProducerIndex),e);returntrue;}四、单消费者批量消费// EventLoop.runAllTasks()批量处理for(;;){RunnabletasktaskQueue.poll();// 无锁出队if(tasknull)break;task.run();// 执行任务}上一篇【第82篇】ChannelOutboundBuffer源码深度解析——Netty写缓冲区的秘密下一篇【第84篇】Netty Channel注册与Selector源码解析