Rho*_*Phi 2 python parallel-processing ray
我在射线中有一些远程函数提交用于计算。在使用它们之前,ray.get我想首先检查它们是否已完成,以便在它们计算时我可以继续做其他事情。
我也真的在考虑维护一本具有这种结构的字典
{
{ 'JSON of parameters used in the calculation': OBJECTid},
...
}
Run Code Online (Sandbox Code Playgroud)
这样我就可以定期阅读这本字典并收集已完成的 OBJECTid。为此,我需要询问任务管理器以了解 OBJECTid 是否已完成。
在这个页面上我似乎看到了有趣的函数,例如ray.objects()函数。然而,这似乎在我的笔记本中不可用,尽管我看到那里列出了许多其他功能,例如 、ray.init()等ray.shutdown()。列出的所有功能Inspect the Cluster State似乎都丢失了,也许我错过了一些重要的步骤(导入?)
事实证明这些ray.wait函数可以做到这一点。将超时设置为零是关键,否则会阻塞内核。
ready_ids, _remaining_ids = ray.wait([OBJECTid],timeout=0)
Run Code Online (Sandbox Code Playgroud)
| 归档时间: |
|
| 查看次数: |
1068 次 |
| 最近记录: |