python - IPython 并行 LoadBalancedView 任务分配细节

Question

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

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

谢谢！

Answer 1

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