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.t
val init : int -> int -> (string -> unit) -> unit
init 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
simple_init ()
does a simple initialization. i.e. with
default parameters if the library is not yet initialised.
Note: this function is automatically called Lwt_preemptive.detach
.
val get_bounds : unit -> int * int
get_bounds ()
returns the minimum and the maximum number of
preemptive threads.val set_bounds : int * int -> unit
set_bounds (min, max)
set the minimum and the maximum number
of preemptive threads.val set_max_number_of_threads_queued : int -> unit
Lwt_preemptive.detach
will
sleep until a thread is available.val get_max_number_of_threads_queued : unit -> int