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

撰写回答
你尚未登录,登录后可以
  • 和开发者交流问题的细节
  • 关注并接收问题和回答的更新提醒
  • 参与内容的编辑和改进,让解决方法与时俱进