const MAX_COUNT int = 1024
for i := 0; i < MAX_COUNT; i++ {
go func() {
for conn := range conn_chan {
//do somthing
}
}()
}
//可以理解为 循环启动多个 conn_chan 实例 监听吗
确保conn_chan来的消息,能够尽可能的多占用cpu性能来执行。
conn_chan依然只有一个,只是如果任务执行期间有多条消息抵达,会最大调用1024个协程。
#1