libearth.compat.parallel — Threading-related compatibility layer

libearth.compat.parallel.cpu_count()

Get the number of CPU cores.

Returns:the number of cpu cores Return type:numbers.Integral

libearth.compat.parallel.parallel_map(pool_size, function, iterable, *iterables)

Parallel vesion of builtin map() except of some differences:

• It takes a more argument at first: pool_size.
• The function applications will be done in parallel.
• The order of arguments to results are not maintained. You should treat these as a set.
• The result is a lazy iterable. Although the function immediately returns an iterable, it might block if some results are not completely ready when it’s iterated.

Parameters:

• pool_size (numbers.Integral) – the number of workers
• function (collections.Callable) – the function to apply iterables as its arguments
• iterable (collections.Iterable) – function argument values

Returns:

a promise iterable to future results

Return type:

collections.Iterable

Changed in version 0.1.1: Errored values are raised at the lastest.