我在看pyspider 的源码的时候,看到processor 处理完成task 的时候,会将处理的描述一个 status_pack放入status_queue中。但是没弄清楚scheduler 在rpc模式下怎么处理status_queue 的流程。发现有on_task_done 这个方法可以处理status_queue。但是xmlrpc的模式下好像没有调用这个方法?
我在看pyspider 的源码的时候,看到processor 处理完成task 的时候,会将处理的描述一个 status_pack放入status_queue中。但是没弄清楚scheduler 在rpc模式下怎么处理status_queue 的流程。发现有on_task_done 这个方法可以处理status_queue。但是xmlrpc的模式下好像没有调用这个方法?
主线程不断读取 status_queue 处理。
xmlrpc 只是 scheduler 附加的一个东西,它运行在一个独立线程中。无论是否运行它,scheduler 都会处理 status_queue