package hack_parallel

  1. Overview
  2. Docs

Module Std.WorkerSource

Sourceexception Worker_exited_abnormally of int * Unix.process_status
Sourceexception Worker_oomed

Worker killed by Out Of Memory.

Sourceexception Worker_busy

Raise this exception when sending work to a worker that is already busy. * We should never be doing that, and this is an assertion error.

Sourceexception Worker_killed

Raise this exception when sending work to a worker that is already killed. * We should never be doing that, and this is an assertion error.

Sourcetype send_job_failure =
  1. | Worker_already_exited of Unix.process_status
  2. | Other_send_job_failure of exn
Sourceexception Worker_failed_to_send_job of send_job_failure
Sourcetype t
Sourcetype 'a handle
Sourcetype 'a entry
Sourceval register_entry_point : restore:('a -> unit) -> 'a entry
Sourceval make : saved_state:'a -> entry:'a entry -> nbr_procs:int -> gc_control:Gc.control -> heap_handle:SharedMem.handle -> t list

Creates a pool of workers.

Sourceval call : t -> ('a -> 'b) -> 'a -> 'b handle
Sourceval get_result : 'a handle -> 'a
Sourcetype 'a selected = {
  1. readys : 'a handle list;
  2. waiters : 'a handle list;
}
Sourceval select : 'a handle list -> 'a selected
Sourceval get_worker : 'a handle -> t
Sourceval killall : unit -> unit
Sourceval current_worker_id : unit -> int