分析了一下你这个代码打印一定是阻塞在了读取 taskChan ，为什么堵塞，大概率是协程池 invoke 的时候堵塞了，我换成 go 携程跑没问题。具体为什么可能需要探索下 ants
go func() {
for task := range taskChan {
fmt.Printf("task: %s\n", task)
// err := producerPool.Invoke(task)
// if err != nil {
// fmt.Printf("failed to producerPool Invoke, err: %s\n", err)
// return
// }
go produceTasks(task, taskChan, resultChan, &counter, &wg)
}
}()