IPython并行LoadBalancedView任务分配详情

Question

我有几个关于IPython并行LoadBalancedView类的问题，我在文档中找不到。

1. LoadBalancedView如何处理进入和退出池的节点？它是否重新计算负载并重新分配？否则一旦节点加入较旧的节点仍然会备份任务。
2. 当任务被添加到池中时，是基于负载立即分配的任务还是在节点完成任务后“释放”后立即分配的任务？我只是很好奇绑定分配何时发生，或者由于某些节点更快等原因总是重新洗牌。

谢谢！

Answer 1

我跑了一些测试。在apply'd之后，LoadBalancedView立即将任务分配给引擎（节点）。如果更多节点稍后加入，则不会重新计算加载，并且这些任务将留给原始引擎完成。只有在引擎注册到控制器后创建的任务才能分配给该引擎。