quri_parts.core.utils.concurrent module#

execute_concurrently(fn, common_input, individual_inputs, executor=None, concurrency=1)#

Execute the given function for each input concurrently and returns all the results as a sequence.

If executor is None, the executions are performed in sequence. If an executor is given, the function is executed for each input concurrently using Executor.map().

Parameters:

  • fn (Callable[[T_common, Sequence[T_individual]], Iterable[R]]) –

  • common_input (T_common) –

  • individual_inputs (Iterable[T_individual]) –

  • executor (Optional['Executor']) –

  • concurrency (int) –

Return type:

Sequence[R]