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

0
2
raynbinghan
我去,每次问了问题后就明白了 ,好烦 O(∩_∩)
2020-08-02
共2条回复

Google资深工程师深度讲解Go语言 由浅入深掌握Go语言

语法+分布式爬虫实战 为转型工程师量身打造

5995 学习 · 1909 问题

查看课程