parList

Evaluate each element of a list in parallel according to given strategy. Equivalent to parTraversable at the list type. Warning: This strategy evaluates the spine of the list and thus does not work on infinite lists.

Like parConcat but works on a list of streams.

>>> parList modifier = Stream.parConcat modifier . Stream.fromList

Divides a list into chunks, and applies the strategy evalList strat to each chunk in parallel. If the chunk size is 1 or less, parListChunk is equivalent to parList This function may be replaced by a more generic clustering infrastructure in the future. Warning: This strategy evaluates the spine of the list and thus does not work on infinite lists.

Like evalListN, but evaluates the first n elements in parallel.

Like evalListNth, but evaluates the nth element in parallel.

Like evalListSplitAt, but evaluates both sublists in parallel.

Like parListLazy but with eager on.

>>> parListEager = Stream.parList (Stream.eager True)

Like parListEager but stops the output as soon as the first stream stops.

>>> parListEagerFst = Stream.parList (Stream.eager True . Stream.stopWhen Stream.FirstStops)

Like parListEager but stops the output as soon as any of the two streams stops. Definition:

>>> parListEagerMin = Stream.parList (Stream.eager True . Stream.stopWhen Stream.AnyStops)

Like parListLazy but interleaves the streams fairly instead of prioritizing the left stream. This schedules all streams in a round robin fashion over limited number of threads.

>>> parListInterleaved = Stream.parList (Stream.interleaved True)

Like concat but works on a list of streams.

>>> parListLazy = Stream.parList id

Like parListLazy but with ordered on.

>>> parListOrdered = Stream.parList (Stream.ordered True)