@@ -114,7 +114,7 @@ func (d *ChanDispatcher) dispatch() {
select {
case msg, ok := <-d.MsgQueue:
if ok {
- // 从工作管道池中尝试取出一个空闲（未阻塞）的工作管道，无空闲工作管道时阻塞
+ // 从工作管道池中尝试取出一个空闲的工作管道（每次取用工作管道会从池中取出去，消息处理完再放回池子，所以池子中的都是空闲的），无空闲工作管道（池子中无消息）时阻塞
jobChannel, isOpen := <-d.WorkerPool
if isOpen {
// 将一条消息发送给成功取出的工作管道
marion