ContextThreadPoolExecutor#
- class langchain_core.runnables.config.ContextThreadPoolExecutor(max_workers=None, thread_name_prefix='', initializer=None, initargs=())[来源]#
将上下文复制到子线程的ThreadPoolExecutor。
初始化一个新的ThreadPoolExecutor实例。
- Parameters:
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实例。
- Parameters:
max_workers – 可用于执行给定调用的最大线程数。
thread_name_prefix – 一个可选的名称前缀，用于给我们的线程命名。
initializer – 用于初始化工作线程的可调用对象。
initargs – 传递给初始化器的参数元组。
- map(fn: Callable[[...], T], *iterables: Iterable[Any], timeout: float | None = None, chunksize: int = 1) Iterator[T][来源]#
将函数映射到多个可迭代对象。
- Parameters:
fn (Callable[..., T]) – 要映射的函数。
*iterables (Iterable[Any]) – 要映射的可迭代对象。
timeout (float | None, optional) – 映射的超时时间。 默认为 None。
chunksize (int, optional) – 用于映射的块大小。默认为1。
- Returns:
映射函数的迭代器。
- Return type:
迭代器[T]
- shutdown(wait=True, *, cancel_futures=False)#
清理与Executor相关的资源。
多次调用此方法是安全的。否则，在此方法之后不能调用其他方法。
- Parameters:
wait – 如果为True，则关闭操作将不会返回，直到所有正在运行的futures执行完毕并且执行器使用的资源已被回收。
cancel_futures – 如果为True，则关闭时将取消所有待处理的futures。已完成或正在运行的futures将不会被取消。