Scheduler 控制 status_queue 的疑问

我在看pyspider 的源码的时候,看到processor 处理完成task 的时候,会将处理的描述一个 status_pack放入status_queue中。但是没弄清楚scheduler 在rpc模式下怎么处理status_queue 的流程。发现有on_task_done 这个方法可以处理status_queue。但是xmlrpc的模式下好像没有调用这个方法?

阅读 2.2k
1 个回答

主线程不断读取 status_queue 处理。
xmlrpc 只是 scheduler 附加的一个东西,它运行在一个独立线程中。无论是否运行它,scheduler 都会处理 status_queue