采纳答案成功!
向帮助你的同学说点啥吧!感谢那些助人为乐的人
一直没看懂,结构体里面包含了一个一个接口?
这里的SimpleScheduler实现了Scheduler接口。Go语言中,只要定义ConfigureMasterWorkerChan和Submit两个函数,就认为实现了Scheduler接口。
c神,请问把scheduler定义在concurrent结构里和直接让concurrent去实现scheduler有什么区别?
这里是一个模块的划分。我在这里分出一个engine模块和一个scheduler模块。 engine模块懂业务逻辑,它负责推动爬虫前进,把worker这里拿来的result进行处理,并交由scheduler进行分发。 scheduler不懂业务逻辑,它只会分发。我们也看到最后我们实现了一个SimpleScheduler,一个QueuedScheduler,它们都能和ConcurrentEngine协同工作。
豁然开朗!谢谢c神!
登录后可查看更多问答,登录/注册
语法+分布式爬虫实战 为转型工程师量身打造
3.8k 14
744 1
2.1k 1
1.1k 12