def par_map

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

import Base

71# List.map(f, xs), on at most `workers` parallel parts.
72def par_map(~A: Type, ~B: Type, ~f: A -> B, workers: U32, xs: List<A>) -> List<B>:
73  par_map.list.top(~A, ~B, ~f, U32.log2(workers), count(A, xs))