Previous  Up  

Module Raw_scheduler.T

module T: sig .. end
type t = {
   mutable check_access :(unit -> unit) option;
   jobs :Raw_scheduler.Execution_context.t Job.t Jobs.t Core.Std.sexp_opaque;
   mutable main_execution_context :Raw_scheduler.Execution_context.t;
   mutable current_execution_context :Raw_scheduler.Execution_context.t;
   mutable max_num_jobs_per_priority_per_cycle :int;
   mutable uncaught_exn :Core.Std.Error.t option;
   mutable global_kill_index :Kill_index.t;
   mutable num_jobs_run :int;
   mutable cycle_count :int;
   mutable cycle_start :Core.Std.Time.t;
   mutable last_cycle_time :Core.Std.Time.Span.t;
   cycle_times :Core.Std.Time.Span.t Raw_scheduler.tail;
   mutable last_cycle_num_jobs :int;
   cycle_num_jobs :int Raw_scheduler.tail;
   events :Raw_scheduler.Execution_context.t Job.t Import.Timing_wheel.t;
   finalizer_jobs :Raw_scheduler.Execution_context.t Job.t Core.Std.Thread_safe_queue.t
Core.Std.sexp_opaque;
   mutable thread_safe_finalizer_hook :unit -> unit;
} 
val sexp_of_t : t -> Sexplib.Sexp.t
val thread_safe_finalizer_hook : t -> unit -> unit
val set_thread_safe_finalizer_hook : t -> (unit -> unit) -> unit
val finalizer_jobs : t ->
       Raw_scheduler.Execution_context.t Job.t Core.Std.Thread_safe_queue.t
       Core.Std.sexp_opaque
val events : t ->
       Raw_scheduler.Execution_context.t Job.t Import.Timing_wheel.t
val cycle_num_jobs : t -> int Raw_scheduler.tail
val last_cycle_num_jobs : t -> int
val set_last_cycle_num_jobs : t -> int -> unit
val cycle_times : t -> Core.Std.Time.Span.t Raw_scheduler.tail
val last_cycle_time : t -> Core.Std.Time.Span.t
val set_last_cycle_time : t -> Core.Std.Time.Span.t -> unit
val cycle_start : t -> Core.Std.Time.t
val set_cycle_start : t -> Core.Std.Time.t -> unit
val cycle_count : t -> int
val set_cycle_count : t -> int -> unit
val num_jobs_run : t -> int
val set_num_jobs_run : t -> int -> unit
val global_kill_index : t -> Kill_index.t
val set_global_kill_index : t -> Kill_index.t -> unit
val uncaught_exn : t -> Core.Std.Error.t option
val set_uncaught_exn : t -> Core.Std.Error.t option -> unit
val max_num_jobs_per_priority_per_cycle : t -> int
val set_max_num_jobs_per_priority_per_cycle : t -> int -> unit
val current_execution_context : t -> Raw_scheduler.Execution_context.t
val set_current_execution_context : t -> Raw_scheduler.Execution_context.t -> unit
val main_execution_context : t -> Raw_scheduler.Execution_context.t
val set_main_execution_context : t -> Raw_scheduler.Execution_context.t -> unit
val jobs : t ->
       Raw_scheduler.Execution_context.t Job.t Jobs.t Core.Std.sexp_opaque
val check_access : t -> (unit -> unit) option
val set_check_access : t -> (unit -> unit) option -> unit
module Fields: sig .. end