Functions

List of functions in the ude.concurrency namespace.

Entity Name	Description
resolve_worker_count	Resolves the number of worker threads to use.
run_concurrently	Runs a function concurrently over an iterable of items.

Generated with Flude

Directory & Entity Index

Entity Name Summary / Description

Resolves the number of worker threads to use.

If a configured value is provided, it is returned. Otherwise, it defaults to os.cpu_count(), with a floor of 1 if os.cpu_count() is None.

Returns:

The resolved number of worker threads (>= 1).

resolve_worker_count(configured: Optional) -> int

Resolves the number of worker threads to use.

If a configured value is provided, it is returned. Otherwise, it defaults to os.cpu_count(), with a floor of 1 if os.cpu_count() is None.

Runs a function concurrently over an iterable of items.

Returns:

A list of results corresponding to the input items, in the exact original order.

run_concurrently(func: Callable, func: R], items: Iterable, max_workers: Optional) -> List[R]

Runs a function concurrently over an iterable of items.

Returns:

A list of results corresponding to the input items, in the exact original order.

Parameter	Type	Description
func	`Callable`	The function to apply to each item.
func	`R]`	The function to apply to each item.
items	`Iterable`	The iterable of items to process.
max_workers	`Optional`	The configured worker count, or None to resolve via

Generated with Flude