sync_async_collector¶
- torchrl.trainers.helpers.sync_async_collector(env_fns: Union[Callable, List[Callable]], env_kwargs: Optional[Union[dict, List[dict]]], num_env_per_collector: Optional[int] = None, num_collectors: Optional[int] = None, **kwargs) MultiaSyncDataCollector[source]¶
執行非同步收集器,每個收集器運行同步環境。
環境型別可以相同或不同。在後一種情況下,env_fns 應該是一個列表,其中包含各種環境的所有建立函式,並且策略應該批次處理這些環境。
- 引數:
env_fns – 返回 EnvBase 類例項的可呼叫物件(或可呼叫物件列表)。
env_kwargs – 可選。包含正在建立的環境的 kwargs 的字典(或字典列表)。
num_env_per_collector – 每個資料收集器的環境數量。num_env_per_collector * num_collectors 的乘積應小於或等於可用 worker 數量。
num_collectors – 並行執行的資料收集器數量。
**kwargs – 傳遞給資料收集器的其他 kwargs