ContextThreadPoolExecutor#

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

ThreadPoolExecutor that copies the context to the child thread.

Initializes a new ThreadPoolExecutor instance.

Parameters:

  • max_workers – The maximum number of threads that can be used to execute the given calls.

  • thread_name_prefix – An optional name prefix to give our threads.

  • initializer – A callable used to initialize worker threads.

  • initargs – A tuple of arguments to pass to the initializer.

Methods

__init__([max_workers, thread_name_prefix, ...])

Initializes a new ThreadPoolExecutor instance.

map(fn, *iterables[, timeout, chunksize])

Map a function to multiple iterables.

shutdown([wait, cancel_futures])

Clean-up the resources associated with the Executor.

submit(func, *args, **kwargs)

Submit a function to the executor.
__init__(max_workers=None, thread_name_prefix='', initializer=None, initargs=())#

Initializes a new ThreadPoolExecutor instance.

Parameters:

  • max_workers – The maximum number of threads that can be used to execute the given calls.

  • thread_name_prefix – An optional name prefix to give our threads.

  • initializer – A callable used to initialize worker threads.

  • initargs – A tuple of arguments to pass to the initializer.

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

Map a function to multiple iterables.

Parameters:

  • fn (Callable[..., T]) – The function to map.

  • *iterables (Iterable[Any]) – The iterables to map over.

  • timeout (float | None, optional) – The timeout for the map. Defaults to None.

  • chunksize (int, optional) – The chunksize for the map. Defaults to 1.

Returns:

The iterator for the mapped function.

Return type:

Iterator[T]

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

Clean-up the resources associated with the Executor.

It is safe to call this method several times. Otherwise, no other methods can be called after this one.

Parameters:

  • wait – If True then shutdown will not return until all running futures have finished executing and the resources used by the executor have been reclaimed.

  • cancel_futures – If True then shutdown will cancel all pending futures. Futures that are completed or running will not be cancelled.

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

Submit a function to the executor.

Parameters:

  • func (Callable[..., T]) – The function to submit.

  • *args (Any) – The positional arguments to the function.

  • **kwargs (Any) – The keyword arguments to the function.

Returns:

The future for the function.

Return type:

Future[T]