package async_kernel

  1. Overview
  2. Docs
package async_kernel
Legend:
Library
Module
Module type
Parameter
Class
Class type
type t = {
  1. mutable check_access : (unit -> unit) option;
  2. mutable job_pool : (Async_kernel__.Types.Execution_context.t, Obj.t -> unit, Obj.t) Core_kernel.Pool.Slots.t3 Core_kernel.Pool.t;
  3. normal_priority_jobs : Async_kernel__.Types.Job_queue.t;
  4. low_priority_jobs : Async_kernel__.Types.Job_queue.t;
  5. very_low_priority_workers : Async_kernel__.Types.Very_low_priority_worker.t Core_kernel.Deque.t;
  6. mutable main_execution_context : Async_kernel__.Types.Execution_context.t;
  7. mutable current_execution_context : Async_kernel__.Types.Execution_context.t;
  8. mutable uncaught_exn : (Core_kernel.Exn.t * Core_kernel.Sexp.t) option;
  9. mutable cycle_count : int;
  10. mutable cycle_start : Base__.Int63_backends.Dynamic.t;
  11. mutable run_every_cycle_start : (unit -> unit) list;
  12. mutable last_cycle_time : Core_kernel.Core_kernel_private.Time_ns_alternate_sexp.Span.t;
  13. mutable last_cycle_num_jobs : int;
  14. mutable advance_synchronous_wall_clock : (now:Base__.Int63_backends.Dynamic.t -> unit) option;
  15. mutable time_source : Core_kernel.read_write Async_kernel__.Types.Time_source.t1;
  16. external_jobs : Async_kernel__.Types.External_job.t Core_kernel.Thread_safe_queue.t;
  17. mutable thread_safe_external_job_hook : unit -> unit;
  18. mutable job_queued_hook : (Priority.t -> unit) option;
  19. mutable event_added_hook : (Base__.Int63_backends.Dynamic.t -> unit) option;
  20. mutable yield : unit Async_kernel__.Types.Bvar.t;
  21. mutable yield_until_no_jobs_remain : unit Async_kernel__.Types.Bvar.t;
  22. mutable check_invariants : bool;
  23. mutable max_num_jobs_per_priority_per_cycle : (int, Async_kernel__.Config.Max_num_jobs_per_priority_per_cycle.witness) Core_kernel.Validated.t;
  24. mutable record_backtraces : bool;
  25. mutable on_start_of_cycle : unit -> unit;
  26. mutable on_end_of_cycle : unit -> unit;
}
val events : t -> (Async_kernel__Types.Execution_context.t, Obj.t -> unit, Obj.t) Core_kernel.Pool.Slots.t3 Core_kernel.Pool.Pointer.t Core_kernel.Timing_wheel_ns.t
val set_execution_context : t -> Async_kernel__Types.Execution_context.t -> unit