自定义类型实现sort接口

utils/queue/chan_pool_test.go

@@ -24,7 +24,6 @@ func TestChanPool(t *testing.T) {
 	// 启动工作管道池调度器
 	msgQueue := make(chan interface{}, 0) // 输入队列
 	NewChanDispatcher(msgQueue, maxWorkers).Run(
-		//NewChanDispatcherWithCapacity(msgQueue, maxWorkers, 5).Run(
 		func(workerId int, msg interface{}) {
 			if n, ok := msg.(*testMsg); ok {
 				fmt.Printf("worker %d received msg %d\n", workerId, n.ID)