Module Async_kernel__.Job_queue
module Scheduler = Async_kernel__.Scheduler0
type t
= Async_kernel__.Types.Job_queue.t
val sexp_of_t : t -> Ppx_sexp_conv_lib.Sexp.t
val create : unit -> t
val enqueue : t -> Async_kernel.Execution_context.t -> ('a -> unit) -> 'a -> unit
val clear : t -> unit
val set_jobs_left_this_cycle : t -> int -> unit
val can_run_a_job : t -> bool
val length : t -> int
val run_jobs : t -> Scheduler.t -> (unit, exn * Core_kernel.Backtrace.t) Core_kernel.Result.t
val num_jobs_run : t -> int