Skip to content

Latest commit

 

History

History
19 lines (13 loc) · 303 Bytes

File metadata and controls

19 lines (13 loc) · 303 Bytes

WorkParallelizer

WorkParallelizer processes enumerable data concurrently.

Installation

mix deps.get

Usage

data = 1..50

worker = fn chunk -> Enum.sum(chunk) end

distributor = fn data -> Enum.chunk_every(data, 5) end

WorkParallelizer.process(data, worker, distributor)