ParallelStream.Mapper (Parallel Stream v1.1.0) View Source

The map iterator implementation

Link to this section Summary

Creates a stream that will apply the given function on enumeration in parallel and return the functions return value.

Creates a stream that will apply the given function on enumeration in parallel and return the functions return value.

These are the options:

:num_workers – The number of parallel operations to run when running the stream.
:worker_work_ratio – The available work per worker, defaults to 5. Higher rates will mean more work sharing, but might also lead to work fragmentation slowing down the queues.

Map and duplicate the numbers:

iex> parallel_stream = 1..5 |> ParallelStream.map(fn i -> i * 2 end)
iex> parallel_stream |> Enum.to_list
[2, 4, 6, 8, 10]