request := <- in 这里的in什么时候才会收到数据呢?
来源:16-4 队列实现调度器
弱弱小乖乖
2018-04-22
func createWorker(out chan ParseResult, s Scheduler){
in := make(chan Request)
go func() {
for {
// tell scheduler i'm ready
s.WorkerReady(in)
request := <- in
result, err := worker(request)
if err != nil {
continue
}
out <- result
}
}()
}request := <- in 这一句,应该是in等待接收数据,接收到以后给request吧 ?那什么地方在不断的给in分发数据呢?
写回答
1回答
-
就是学不到
2018-04-23
activeWorker <- activeRequest
022020-08-02
相似问题