ray.util.ActorPool.has_next

ActorPool.has_next()

返回是否有任何待返回的结果。

返回:

如果有任何待处理的结果尚未返回，则为真。

示例

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.has_next())
print(pool.get_next())
print(pool.has_next())

True
2
False