Version last
This is a preliminary version of the documentation. Help us to improve it by filling tickets. We are looking for native english speakers to proof read the documentation. Contact us!
module Lwt_preemptive:This module allows to mix preemptive threads withsig..end
Lwt cooperative threads. It maintains an extensible pool of preemptive threads to with you can detach computations.val detach : ('a -> 'b) -> 'a -> 'b Lwt.tval init : int -> int -> (string -> unit) -> unit Lwt.tinit min max log initialises this module. i.e. it launches the minimum number of preemptive threads and starts the dispatcher.val simple_init : unit -> unit Lwt.tsimple_init () does a simple initialization. i.e. with default parameters if the library is not yet initialised.It returns the dispatcher thread.
Note: this function is automatically called Lwt_preemptive.detach.
val get_bounds : unit -> int * intget_bounds () returns the minimum and the maximum number of preemptive threads.val set_bounds : int * int -> unitset_bounds (min, max) set the minimum and the maximum number of preemptive threads.val set_max_number_of_threads_queued : int -> unitLwt_preemptive.detach will sleep until a thread is available.val get_max_number_of_threads_queued : unit -> int