package nproc

  1. Overview
  2. Docs
Legend:
Library
Module
Module type
Parameter
Class
Class type
type t
type worker_info = private {
  1. worker_id : int;
  2. worker_loop : 'a. unit -> 'a;
}
exception Start_worker of worker_info
val create : ?init:(worker_info -> unit) -> int -> t * unit Lwt.t
val close : t -> unit Lwt.t
val terminate : t -> unit
val submit : t -> f:('a -> 'b) -> 'a -> 'b option Lwt.t
val iter_stream : ?granularity:int -> ?init:(worker_info -> unit) -> nproc:int -> f:('a -> 'b) -> g:('b option -> unit) -> 'a Stream.t -> unit
val log_error : (string -> unit) ref
val log_info : (string -> unit) ref
val string_of_exn : (exn -> string) ref
module Full : sig ... end