ray.util.ActorPool

class ray.util.ActorPool(actors: list)

基类：object

用于操作固定演员池的实用类。

参数:

actors – 在此池中使用的 Ray 角色句柄列表。

示例

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])
print(list(pool.map(lambda a, v: a.double.remote(v),
                    [1, 2, 3, 4])))

[2, 4, 6, 8]

开发者API: 此API可能会在Ray的次要版本之间发生变化。

方法

get_next	按顺序返回下一个待处理的结果。
get_next_unordered	返回任何下一个待处理的结果。
has_free	返回是否有任何空闲的演员可用。
has_next	返回是否有任何待返回的结果。
map	在执行者和值上并行应用给定的函数。
map_unordered	类似于 map()，但返回一个无序的迭代器。
pop_idle	从池中移除一个空闲的演员。
push	将一个新的执行者推入当前空闲执行者列表中。
submit	在池中安排一个任务运行。