package hack_parallel

  1. Overview
  2. Docs
package hack_parallel
Legend:
Page
Library
Module
Module type
Parameter
Class
Class type
Source

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
OCaml

Innovation. Community. Security.

GitHub Discord Twitter Peertube RSS
About
Changelog Releases Industrial Users Academic Users Why OCaml
Ecosystem
Packages Community Events OCaml Planet Jobs
Resources
Install OCaml Get Started Platform Tools Language Manual Standard Library API Books Exercises Papers OCaml Playground Logo
Policies
Carbon Footprint Governance Privacy Code of Conduct