采纳答案成功!
向帮助你的同学说点啥吧!感谢那些助人为乐的人
一直没看懂,结构体里面包含了一个一个接口?
这里的SimpleScheduler实现了Scheduler接口。Go语言中,只要定义ConfigureMasterWorkerChan和Submit两个函数,就认为实现了Scheduler接口。
c神,请问把scheduler定义在concurrent结构里和直接让concurrent去实现scheduler有什么区别?
这里是一个模块的划分。我在这里分出一个engine模块和一个scheduler模块。 engine模块懂业务逻辑,它负责推动爬虫前进,把worker这里拿来的result进行处理,并交由scheduler进行分发。 scheduler不懂业务逻辑,它只会分发。我们也看到最后我们实现了一个SimpleScheduler,一个QueuedScheduler,它们都能和ConcurrentEngine协同工作。
豁然开朗!谢谢c神!
登录后可查看更多问答,登录/注册
语法+分布式爬虫实战 为转型工程师量身打造
4.2k 14
1.2k 1
2.5k 1
1.6k 12
购课补贴联系客服咨询优惠详情
慕课网APP您的移动学习伙伴
扫描二维码关注慕课网微信公众号