package hack_parallel

  1. Overview
  2. Docs

Module Std.BucketSource

Sourcetype 'a bucket =
  1. | Job of 'a
  2. | Wait
  3. | Done
Sourcetype 'a next = unit -> 'a bucket
Sourceval of_list : 'a list -> 'a list bucket
Sourceval make : num_workers:int -> 'a list -> 'a list next
Sourcetype 'a of_n = {
  1. work : 'a;
  2. bucket : int;
  3. total : int;
}
Sourceval make_n_buckets : buckets:int -> split:(bucket:int -> 'a) -> 'a of_n next