ray.rllib.env.env_runner_group.EnvRunnerGroup.foreach_worker_async#

EnvRunnerGroup.foreach_worker_async(func: Callable[[EnvRunner], T], *, healthy_only: bool = True, remote_worker_ids: List[int] = None) → int[源代码]#

使用每个工作线程作为参数异步调用给定的函数。

foreach_worker_async() 不会直接返回结果。相反，可以使用 fetch_ready_async_reqs() 在结果可用时以异步方式拉取结果。

参数:

  • func – 每个工作线程调用的函数（仅作为参数）。

  • healthy_only – 仅对已知健康的工人应用 func。

  • remote_worker_ids – 在选定的一组远程工作者上应用 func。

返回:

实际发出的异步请求的数量。这是 remote_worker_ids 的长度（如果 remote_worker_ids 为 None，则为 self.num_remote_workers()）减去由于远程工作者的 max_remote_requests_in_flight_per_actor 计数器已达到而未发出的请求数量。

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