Module Throttle

module Throttle: Throttle

type t 

include Invariant.S

val create : continue_on_error:bool -> max_concurrent_jobs:int -> t

type 'a outcome = [ `Aborted | `Ok of 'a | `Raised of exn ] 

module Job: sig .. end

val enqueue_job : t -> 'a Job.t -> unit

val enqueue' : t -> (unit -> 'a Deferred.t) -> 'a outcome Deferred.t

val enqueue : t -> (unit -> 'a Deferred.t) -> 'a Deferred.t

val prior_jobs_done : t -> unit Deferred.t

val num_jobs_waiting_to_start : t -> int

module Sequencer: sig .. end

val sexp_of_t : t -> Sexplib.Sexp.t

If some job raises an exception, then the throttle will stop, unless continue_on_error is true.

enqueue t job schedules job to be run as soon as possible. Jobs are guaranteed to be started in the order they are enqueued.

enqueue raises an exception if the throttle is dead.

prior_jobs_done t becomes determined when all of the jobs that were previously enqueued in t have completed.

A sequencer is a throttle that is:

• specialized to only allow one job at a time and to not continue on error, and
• generalized to carry its own state, and enforce mutually exclusive access to that state by the jobs