gather_with_concurrency#

async langchain_core.runnables.utils.gather_with_concurrency(n: int | None, *coros: Coroutine) list[source]#

收集协程,并限制并发协程的数量。

Parameters:
  • n (int | None) – 并发运行的协程数量。

  • *coros (Coroutine) – 要运行的协程。

Returns:

协程的结果。

Return type:

列表