def par_reduce

bend-kit-concurrency@0.2.0.0 · concurrency.bend:109

import Base

109# The left fold of xs from z, on at most `workers` parallel parts. f must be
110# associative and z its identity.
111def par_reduce(~A: Data, ~f: A -> A -> A, workers: U32, +z: A, xs: List<A>) -> A:
112  par_reduce.list.top(~A, ~f, U32.log2(workers), z, count(A, xs))