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
今日阅读排行
一周阅读排行