execution

Utilities for execution of measurements.

concurrently(*callables)

Run an arbitrary number of functions concurrently.

Parameters:

Name	Type	Description	Default
callables	Callable[[], Any]	The callables to execute	()

Returns:

Type	Description
list[Any]	The results of all callables, in the order in which they were passed to call

Source code in mlte/measurement/utility/execution.py

def concurrently(*callables: Callable[[], Any]) -> list[Any]:
    """
    Run an arbitrary number of functions concurrently.

    :param callables: The callables to execute

    :return: The results of all callables, in
    the order in which they were passed to call
    """
    with concurrent.futures.ThreadPoolExecutor() as executor:
        futures = [executor.submit(callable) for callable in callables]
        return [future.result() for future in futures]