在Channel结构体中用到了两种优先级队列pqueue.PriorityQueue和inFlightPqueue。 deferredMessages map[MessageID]*pqueue.ItemdeferredPQ pqueue.PriorityQueuedeferredMutex sync.MutexinFlightMessages map[MessageID]