管道池

utils/queue/chan_pool_test.go

@@ -13,8 +13,8 @@ type testMsg struct {
 // "线程池"（golang管道池）单元测试
 func TestChanPool(t *testing.T) {
 	// 参数
-	maxWorkers := 4 // 最大工作管道数
-	msgCount := 100 // 消息数量
+	maxWorkers := 4  // 最大工作管道数
+	msgCount := 1000 // 消息数量
 
 	// 非主逻辑，计数器初始化
 	wg := sync.WaitGroup{} // 同步计数器