langchain_core.runnables.config.ContextThreadPoolExecutor

class langchain_core.runnables.config.ContextThreadPoolExecutor(max_workers=None, thread_name_prefix='', initializer=None, initargs=())

将上下文复制到子线程的ThreadPoolExecutor。

初始化一个新的ThreadPoolExecutor实例。

参数

• max_workers – 可以用于执行给定调用线程的最大数量。

• thread_name_prefix – 可选的线程名称前缀。

• initializer – 用于初始化工作线程的可调用函数。

• initargs – 传递给初始化器参数的元组。

方法

__init__([max_workers, thread_name_prefix, ...])	初始化一个新的ThreadPoolExecutor实例。
map(fn, *iterables[, timeout, chunksize])	将函数映射到多个可迭代对象。
shutdown([wait, cancel_futures])	清理与Executor关联的资源。
submit(func, *args, **kwargs)	将函数提交给执行器。

__init__(max_workers=None, thread_name_prefix='', initializer=None, initargs=())

初始化一个新的ThreadPoolExecutor实例。

参数

• max_workers – 可以用于执行给定调用线程的最大数量。

• thread_name_prefix – 可选的线程名称前缀。

• initializer – 用于初始化工作线程的可调用函数。

• initargs – 传递给初始化器参数的元组。

map(fn: Callable[[...], T], *iterables: Iterable[Any], timeout: Optional[float] = None, chunksize: int = 1) → Iterator[T]

将函数映射到多个可迭代对象。

参数

• fn (Callable[..., T]) – 映射函数。

• *iterables (Iterable[Any]) – 要映射的可迭代对象。

• timeout (float | None, optional) – 映射的超时时间。默认为 None。

• chunksize (int, optional) – 映射的块大小。默认为 1。

返回值

映射函数的迭代器。

返回类型

Iterator[T]

shutdown(wait=True, *, cancel_futures=False)

清理与Executor关联的资源。

此方法可以安全地多次调用。否则，在调用此方法之后，无法调用其他任何方法。

参数

• wait – 如果为 True，则shutdown 不会返回，直到所有正在运行的未来（futures）都已经完成执行，并且执行器使用的资源已经被回收。

• cancel_futures – 如果为 True，则 shutdown 将取消所有挂起（pending）的未来。已完成或正在运行的未来不会取消。

submit(func: ~typing.Callable[[~P], ~langchain_core.runnables.config.T], *args: ~typing.~P, **kwargs: ~typing.~P) → Future[T]

将函数提交给执行器。

参数

• func (Callable[..., T]) – 要提交的函数。

• *args (Any) – 函数的位置参数。

• **kwargs (Any) – 函数的关键字参数。

返回值

函数的未来（future）。

返回类型

Future[T]