Up – Package index » hack_parallel » Library hack_parallel.scheduler » Scheduler

Module `Scheduler`

Copyright (c) 2016-present, Facebook, Inc. Modified work Copyright (c) 2018-2019 Rijnard van Tonder This source code is licensed under the MIT license found in the LICENSE file in the root directory of this source tree.

hack_parallel
- README
- Library hack_parallel
  - Hack_parallel
- Library hack_parallel.collections
- Library hack_parallel.disk
- Library hack_parallel.hack_core
- Library hack_parallel.heap
- Library hack_parallel.hh_json
  - Hh_json
- Library hack_parallel.injection
  - Injector_config
- Library hack_parallel.interface
  - Hack_parallel_intf
- Library hack_parallel.memory
  - Memory
- Library hack_parallel.procs
- Library hack_parallel.scheduler
  - Scheduler
    - Daemon
- Library hack_parallel.socket
  - Socket
- Library hack_parallel.stubs
  - EventLogger
- Library hack_parallel.utils
- Sources

module Daemon = Hack_parallel_intf.Std.Daemon

type t

val create : ?number_of_workers:int -> ?bucket_multiplier:int -> unit -> t

val map_reduce : 
  t ->
  ?bucket_size:int ->
  init:'a ->
  map:('a -> 'b list -> 'c) ->
  reduce:('c -> 'a -> 'a) ->
  'b list ->
  'a

val iter : t -> f:('a list -> unit) -> 'a list -> unit

val single_job : t -> f:('a -> 'b) -> 'a -> 'b

val mock : unit -> t

val destroy : t -> unit