ray.util.ActorPool.get_next

ActorPool.get_next(timeout=None, ignore_if_timedout=False)

按顺序返回下一个待处理的结果。

这将返回由 submit() 产生的下一个结果，最多阻塞指定的时间直到结果可用。

返回:

下一个结果。

抛出:

TimeoutError – 如果达到超时时间。

示例

import ray
from ray.util.actor_pool import ActorPool

@ray.remote
class Actor:
    def double(self, v):
        return 2 * v

a1, a2 = Actor.remote(), Actor.remote()
pool = ActorPool([a1, a2])
pool.submit(lambda a, v: a.double.remote(v), 1)
print(pool.get_next())

2