1

我在提交计算的光线中有一些远​​程函数。在得到它们之前,ray.get我想先检查它们是否完成,这样我就可以在它们计算的同时继续做其他事情。

另外我真的在考虑用这种结构维护一本字典

{
  { 'JSON of parameters used in the calculation': OBJECTid},
   ...
}

这样我就可以定期阅读这本字典并收集完成的 OBJECTid。为此,我需要询问任务管理器以了解 OBJECTid 是否已完成。

在此页面上,我似乎看到了有趣的功能,例如ray.objects()功能。然而,这似乎在我的笔记本中不可用,尽管我看到那里列出了许多其他功能,例如ray.init()ray.shutdown()等。列出的所有功能Inspect the Cluster State似乎都不见了,也许我错过了一些重要的步骤(导入?)

4

1 回答 1

2

事实证明,ray.wait函数可以做到这一点。将超时设置为零是关键,否则会阻塞内核。

ready_ids, _remaining_ids = ray.wait([OBJECTid],timeout=0)
于 2019-06-12T13:32:09.683 回答