package async_kernel

  1. Overview
  2. Docs
package async_kernel
Legend:
Library
Module
Module type
Parameter
Class
Class type
val names : string list
val record_backtraces : ([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, bool) Fieldslib.Field.t_with_perm
val max_num_jobs_per_priority_per_cycle : ([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Async_kernel_config.Max_num_jobs_per_priority_per_cycle.t) Fieldslib.Field.t_with_perm
val check_invariants : ([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, bool) Fieldslib.Field.t_with_perm
val yield_until_no_jobs_remain : ([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (unit, Core.read_write) Async_kernel__.Types.Bvar.t) Fieldslib.Field.t_with_perm
val yield : ([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (unit, Core.read_write) Async_kernel__.Types.Bvar.t) Fieldslib.Field.t_with_perm
val event_added_hook : ([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (Core.Time_ns.t -> unit) option) Fieldslib.Field.t_with_perm
val job_queued_hook : ([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (Priority.t -> unit) option) Fieldslib.Field.t_with_perm
val thread_safe_external_job_hook : ([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, unit -> unit) Fieldslib.Field.t_with_perm
val external_jobs : ([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Async_kernel__.Types.External_job.t Thread_safe_queue.t) Fieldslib.Field.t_with_perm
val time_source : ([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Core.read_write Async_kernel__.Types.Time_source.t1) Fieldslib.Field.t_with_perm
val total_cycle_time : ([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Core.Core_private.Time_ns_alternate_sexp.Span.t) Fieldslib.Field.t_with_perm
val last_cycle_num_jobs : ([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, int) Fieldslib.Field.t_with_perm
val last_cycle_time : ([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Core.Core_private.Time_ns_alternate_sexp.Span.t) Fieldslib.Field.t_with_perm
val run_every_cycle_end_state : ([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (Async_kernel__.Types.Cycle_hook_handle.t, unit -> unit) Core.Hashtbl.t) Fieldslib.Field.t_with_perm
val run_every_cycle_end : ([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (unit -> unit) list) Fieldslib.Field.t_with_perm
val run_every_cycle_start_state : ([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (Async_kernel__.Types.Cycle_hook_handle.t, unit -> unit) Core.Hashtbl.t) Fieldslib.Field.t_with_perm
val run_every_cycle_start : ([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (unit -> unit) list) Fieldslib.Field.t_with_perm
val in_cycle : ([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, bool) Fieldslib.Field.t_with_perm
val cycle_start : ([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Core.Time_ns.t) Fieldslib.Field.t_with_perm
val cycle_count : ([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, int) Fieldslib.Field.t_with_perm
val uncaught_exn : ([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (Core.Exn.t * Core.Sexp.t) option) Fieldslib.Field.t_with_perm
val current_execution_context : ([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Execution_context.t) Fieldslib.Field.t_with_perm
val main_execution_context : ([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Execution_context.t) Fieldslib.Field.t_with_perm
val very_low_priority_workers : ([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Async_kernel__.Types.Very_low_priority_worker.t Core.Deque.t) Fieldslib.Field.t_with_perm
val low_priority_jobs : ([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Async_kernel__.Types.Job_queue.t) Fieldslib.Field.t_with_perm
val normal_priority_jobs : ([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Async_kernel__.Types.Job_queue.t) Fieldslib.Field.t_with_perm
val job_pool : ([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (Execution_context.t, Obj.t -> unit, Obj.t) Tuple_pool.Slots.t3 Tuple_pool.t) Fieldslib.Field.t_with_perm
val check_access : ([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (unit -> unit) option) Fieldslib.Field.t_with_perm
val make_creator : check_access: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (unit -> unit) option) Fieldslib.Field.t_with_perm -> 'a -> ('b -> (unit -> unit) option) * 'c) -> job_pool: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (Execution_context.t, Obj.t -> unit, Obj.t) Tuple_pool.Slots.t3 Tuple_pool.t) Fieldslib.Field.t_with_perm -> 'd -> ('e -> (Execution_context.t, Obj.t -> unit, Obj.t) Tuple_pool.Slots.t3 Tuple_pool.t) * 'f) -> normal_priority_jobs: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Async_kernel__.Types.Job_queue.t) Fieldslib.Field.t_with_perm -> 'g -> ('h -> Async_kernel__.Types.Job_queue.t) * 'i) -> low_priority_jobs: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Async_kernel__.Types.Job_queue.t) Fieldslib.Field.t_with_perm -> 'j -> ('k -> Async_kernel__.Types.Job_queue.t) * 'l) -> very_low_priority_workers: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Async_kernel__.Types.Very_low_priority_worker.t Core.Deque.t) Fieldslib.Field.t_with_perm -> 'm -> ('n -> Async_kernel__.Types.Very_low_priority_worker.t Core.Deque.t) * 'o) -> main_execution_context: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Execution_context.t) Fieldslib.Field.t_with_perm -> 'p -> ('q -> Execution_context.t) * 'r) -> current_execution_context: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Execution_context.t) Fieldslib.Field.t_with_perm -> 's -> ('t -> Execution_context.t) * 'u) -> uncaught_exn: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (Core.Exn.t * Core.Sexp.t) option) Fieldslib.Field.t_with_perm -> 'v -> ('w -> (Core.Exn.t * Core.Sexp.t) option) * 'x) -> cycle_count: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, int) Fieldslib.Field.t_with_perm -> 'y -> ('z -> int) * 'a1) -> cycle_start: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Core.Time_ns.t) Fieldslib.Field.t_with_perm -> 'b1 -> ('c1 -> Core.Time_ns.t) * 'd1) -> in_cycle: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, bool) Fieldslib.Field.t_with_perm -> 'e1 -> ('f1 -> bool) * 'g1) -> run_every_cycle_start: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (unit -> unit) list) Fieldslib.Field.t_with_perm -> 'h1 -> ('i1 -> (unit -> unit) list) * 'j1) -> run_every_cycle_start_state: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (Async_kernel__.Types.Cycle_hook_handle.t, unit -> unit) Core.Hashtbl.t) Fieldslib.Field.t_with_perm -> 'k1 -> ('l1 -> (Async_kernel__.Types.Cycle_hook_handle.t, unit -> unit) Core.Hashtbl.t) * 'm1) -> run_every_cycle_end: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (unit -> unit) list) Fieldslib.Field.t_with_perm -> 'n1 -> ('o1 -> (unit -> unit) list) * 'p1) -> run_every_cycle_end_state: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (Async_kernel__.Types.Cycle_hook_handle.t, unit -> unit) Core.Hashtbl.t) Fieldslib.Field.t_with_perm -> 'q1 -> ('r1 -> (Async_kernel__.Types.Cycle_hook_handle.t, unit -> unit) Core.Hashtbl.t) * 's1) -> last_cycle_time: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Core.Core_private.Time_ns_alternate_sexp.Span.t) Fieldslib.Field.t_with_perm -> 't1 -> ('u1 -> Core.Core_private.Time_ns_alternate_sexp.Span.t) * 'v1) -> last_cycle_num_jobs: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, int) Fieldslib.Field.t_with_perm -> 'w1 -> ('x1 -> int) * 'y1) -> total_cycle_time: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Core.Core_private.Time_ns_alternate_sexp.Span.t) Fieldslib.Field.t_with_perm -> 'z1 -> ('a2 -> Core.Core_private.Time_ns_alternate_sexp.Span.t) * 'b2) -> time_source: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Core.read_write Async_kernel__.Types.Time_source.t1) Fieldslib.Field.t_with_perm -> 'c2 -> ('d2 -> Core.read_write Async_kernel__.Types.Time_source.t1) * 'e2) -> external_jobs: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Async_kernel__.Types.External_job.t Thread_safe_queue.t) Fieldslib.Field.t_with_perm -> 'f2 -> ('g2 -> Async_kernel__.Types.External_job.t Thread_safe_queue.t) * 'h2) -> thread_safe_external_job_hook: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, unit -> unit) Fieldslib.Field.t_with_perm -> 'i2 -> ('j2 -> unit -> unit) * 'k2) -> job_queued_hook: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (Priority.t -> unit) option) Fieldslib.Field.t_with_perm -> 'l2 -> ('m2 -> (Priority.t -> unit) option) * 'n2) -> event_added_hook: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (Core.Time_ns.t -> unit) option) Fieldslib.Field.t_with_perm -> 'o2 -> ('p2 -> (Core.Time_ns.t -> unit) option) * 'q2) -> yield: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (unit, Core.read_write) Async_kernel__.Types.Bvar.t) Fieldslib.Field.t_with_perm -> 'r2 -> ('s2 -> (unit, Core.read_write) Async_kernel__.Types.Bvar.t) * 't2) -> yield_until_no_jobs_remain: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (unit, Core.read_write) Async_kernel__.Types.Bvar.t) Fieldslib.Field.t_with_perm -> 'u2 -> ('v2 -> (unit, Core.read_write) Async_kernel__.Types.Bvar.t) * 'w2) -> check_invariants: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, bool) Fieldslib.Field.t_with_perm -> 'x2 -> ('y2 -> bool) * 'z2) -> max_num_jobs_per_priority_per_cycle: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Async_kernel_config.Max_num_jobs_per_priority_per_cycle.t) Fieldslib.Field.t_with_perm -> 'a3 -> ('b3 -> Async_kernel_config.Max_num_jobs_per_priority_per_cycle.t) * 'c3) -> record_backtraces: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, bool) Fieldslib.Field.t_with_perm -> 'd3 -> ('e3 -> bool) * 'f3) -> 'g3 -> ('h3 -> Async_kernel__.Types.Scheduler.t) * 'i3
val create : check_access:(unit -> unit) option -> job_pool: (Execution_context.t, Obj.t -> unit, Obj.t) Tuple_pool.Slots.t3 Tuple_pool.t -> normal_priority_jobs:Async_kernel__.Types.Job_queue.t -> low_priority_jobs:Async_kernel__.Types.Job_queue.t -> very_low_priority_workers: Async_kernel__.Types.Very_low_priority_worker.t Core.Deque.t -> main_execution_context:Execution_context.t -> current_execution_context:Execution_context.t -> uncaught_exn:(Core.Exn.t * Core.Sexp.t) option -> cycle_count:int -> cycle_start:Core.Time_ns.t -> in_cycle:bool -> run_every_cycle_start:(unit -> unit) list -> run_every_cycle_start_state: (Async_kernel__.Types.Cycle_hook_handle.t, unit -> unit) Core.Hashtbl.t -> run_every_cycle_end:(unit -> unit) list -> run_every_cycle_end_state: (Async_kernel__.Types.Cycle_hook_handle.t, unit -> unit) Core.Hashtbl.t -> last_cycle_time:Core.Core_private.Time_ns_alternate_sexp.Span.t -> last_cycle_num_jobs:int -> total_cycle_time:Core.Core_private.Time_ns_alternate_sexp.Span.t -> time_source:Core.read_write Async_kernel__.Types.Time_source.t1 -> external_jobs:Async_kernel__.Types.External_job.t Thread_safe_queue.t -> thread_safe_external_job_hook:(unit -> unit) -> job_queued_hook:(Priority.t -> unit) option -> event_added_hook:(Core.Time_ns.t -> unit) option -> yield:(unit, Core.read_write) Async_kernel__.Types.Bvar.t -> yield_until_no_jobs_remain: (unit, Core.read_write) Async_kernel__.Types.Bvar.t -> check_invariants:bool -> max_num_jobs_per_priority_per_cycle: Async_kernel_config.Max_num_jobs_per_priority_per_cycle.t -> record_backtraces:bool -> Async_kernel__.Types.Scheduler.t
val map : check_access: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (unit -> unit) option) Fieldslib.Field.t_with_perm -> (unit -> unit) option) -> job_pool: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (Execution_context.t, Obj.t -> unit, Obj.t) Tuple_pool.Slots.t3 Tuple_pool.t) Fieldslib.Field.t_with_perm -> (Execution_context.t, Obj.t -> unit, Obj.t) Tuple_pool.Slots.t3 Tuple_pool.t) -> normal_priority_jobs: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Async_kernel__.Types.Job_queue.t) Fieldslib.Field.t_with_perm -> Async_kernel__.Types.Job_queue.t) -> low_priority_jobs: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Async_kernel__.Types.Job_queue.t) Fieldslib.Field.t_with_perm -> Async_kernel__.Types.Job_queue.t) -> very_low_priority_workers: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Async_kernel__.Types.Very_low_priority_worker.t Core.Deque.t) Fieldslib.Field.t_with_perm -> Async_kernel__.Types.Very_low_priority_worker.t Core.Deque.t) -> main_execution_context: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Execution_context.t) Fieldslib.Field.t_with_perm -> Execution_context.t) -> current_execution_context: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Execution_context.t) Fieldslib.Field.t_with_perm -> Execution_context.t) -> uncaught_exn: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (Core.Exn.t * Core.Sexp.t) option) Fieldslib.Field.t_with_perm -> (Core.Exn.t * Core.Sexp.t) option) -> cycle_count: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, int) Fieldslib.Field.t_with_perm -> int) -> cycle_start: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Core.Time_ns.t) Fieldslib.Field.t_with_perm -> Core.Time_ns.t) -> in_cycle: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, bool) Fieldslib.Field.t_with_perm -> bool) -> run_every_cycle_start: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (unit -> unit) list) Fieldslib.Field.t_with_perm -> (unit -> unit) list) -> run_every_cycle_start_state: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (Async_kernel__.Types.Cycle_hook_handle.t, unit -> unit) Core.Hashtbl.t) Fieldslib.Field.t_with_perm -> (Async_kernel__.Types.Cycle_hook_handle.t, unit -> unit) Core.Hashtbl.t) -> run_every_cycle_end: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (unit -> unit) list) Fieldslib.Field.t_with_perm -> (unit -> unit) list) -> run_every_cycle_end_state: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (Async_kernel__.Types.Cycle_hook_handle.t, unit -> unit) Core.Hashtbl.t) Fieldslib.Field.t_with_perm -> (Async_kernel__.Types.Cycle_hook_handle.t, unit -> unit) Core.Hashtbl.t) -> last_cycle_time: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Core.Core_private.Time_ns_alternate_sexp.Span.t) Fieldslib.Field.t_with_perm -> Core.Core_private.Time_ns_alternate_sexp.Span.t) -> last_cycle_num_jobs: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, int) Fieldslib.Field.t_with_perm -> int) -> total_cycle_time: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Core.Core_private.Time_ns_alternate_sexp.Span.t) Fieldslib.Field.t_with_perm -> Core.Core_private.Time_ns_alternate_sexp.Span.t) -> time_source: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Core.read_write Async_kernel__.Types.Time_source.t1) Fieldslib.Field.t_with_perm -> Core.read_write Async_kernel__.Types.Time_source.t1) -> external_jobs: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Async_kernel__.Types.External_job.t Thread_safe_queue.t) Fieldslib.Field.t_with_perm -> Async_kernel__.Types.External_job.t Thread_safe_queue.t) -> thread_safe_external_job_hook: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, unit -> unit) Fieldslib.Field.t_with_perm -> unit -> unit) -> job_queued_hook: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (Priority.t -> unit) option) Fieldslib.Field.t_with_perm -> (Priority.t -> unit) option) -> event_added_hook: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (Core.Time_ns.t -> unit) option) Fieldslib.Field.t_with_perm -> (Core.Time_ns.t -> unit) option) -> yield: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (unit, Core.read_write) Async_kernel__.Types.Bvar.t) Fieldslib.Field.t_with_perm -> (unit, Core.read_write) Async_kernel__.Types.Bvar.t) -> yield_until_no_jobs_remain: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (unit, Core.read_write) Async_kernel__.Types.Bvar.t) Fieldslib.Field.t_with_perm -> (unit, Core.read_write) Async_kernel__.Types.Bvar.t) -> check_invariants: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, bool) Fieldslib.Field.t_with_perm -> bool) -> max_num_jobs_per_priority_per_cycle: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Async_kernel_config.Max_num_jobs_per_priority_per_cycle.t) Fieldslib.Field.t_with_perm -> Async_kernel_config.Max_num_jobs_per_priority_per_cycle.t) -> record_backtraces: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, bool) Fieldslib.Field.t_with_perm -> bool) -> Async_kernel__.Types.Scheduler.t
val iter : check_access: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (unit -> unit) option) Fieldslib.Field.t_with_perm -> unit) -> job_pool: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (Execution_context.t, Obj.t -> unit, Obj.t) Tuple_pool.Slots.t3 Tuple_pool.t) Fieldslib.Field.t_with_perm -> unit) -> normal_priority_jobs: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Async_kernel__.Types.Job_queue.t) Fieldslib.Field.t_with_perm -> unit) -> low_priority_jobs: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Async_kernel__.Types.Job_queue.t) Fieldslib.Field.t_with_perm -> unit) -> very_low_priority_workers: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Async_kernel__.Types.Very_low_priority_worker.t Core.Deque.t) Fieldslib.Field.t_with_perm -> unit) -> main_execution_context: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Execution_context.t) Fieldslib.Field.t_with_perm -> unit) -> current_execution_context: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Execution_context.t) Fieldslib.Field.t_with_perm -> unit) -> uncaught_exn: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (Core.Exn.t * Core.Sexp.t) option) Fieldslib.Field.t_with_perm -> unit) -> cycle_count: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, int) Fieldslib.Field.t_with_perm -> unit) -> cycle_start: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Core.Time_ns.t) Fieldslib.Field.t_with_perm -> unit) -> in_cycle: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, bool) Fieldslib.Field.t_with_perm -> unit) -> run_every_cycle_start: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (unit -> unit) list) Fieldslib.Field.t_with_perm -> unit) -> run_every_cycle_start_state: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (Async_kernel__.Types.Cycle_hook_handle.t, unit -> unit) Core.Hashtbl.t) Fieldslib.Field.t_with_perm -> unit) -> run_every_cycle_end: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (unit -> unit) list) Fieldslib.Field.t_with_perm -> unit) -> run_every_cycle_end_state: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (Async_kernel__.Types.Cycle_hook_handle.t, unit -> unit) Core.Hashtbl.t) Fieldslib.Field.t_with_perm -> unit) -> last_cycle_time: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Core.Core_private.Time_ns_alternate_sexp.Span.t) Fieldslib.Field.t_with_perm -> unit) -> last_cycle_num_jobs: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, int) Fieldslib.Field.t_with_perm -> unit) -> total_cycle_time: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Core.Core_private.Time_ns_alternate_sexp.Span.t) Fieldslib.Field.t_with_perm -> unit) -> time_source: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Core.read_write Async_kernel__.Types.Time_source.t1) Fieldslib.Field.t_with_perm -> unit) -> external_jobs: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Async_kernel__.Types.External_job.t Thread_safe_queue.t) Fieldslib.Field.t_with_perm -> unit) -> thread_safe_external_job_hook: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, unit -> unit) Fieldslib.Field.t_with_perm -> unit) -> job_queued_hook: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (Priority.t -> unit) option) Fieldslib.Field.t_with_perm -> unit) -> event_added_hook: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (Core.Time_ns.t -> unit) option) Fieldslib.Field.t_with_perm -> unit) -> yield: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (unit, Core.read_write) Async_kernel__.Types.Bvar.t) Fieldslib.Field.t_with_perm -> unit) -> yield_until_no_jobs_remain: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (unit, Core.read_write) Async_kernel__.Types.Bvar.t) Fieldslib.Field.t_with_perm -> unit) -> check_invariants: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, bool) Fieldslib.Field.t_with_perm -> unit) -> max_num_jobs_per_priority_per_cycle: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Async_kernel_config.Max_num_jobs_per_priority_per_cycle.t) Fieldslib.Field.t_with_perm -> unit) -> record_backtraces: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, bool) Fieldslib.Field.t_with_perm -> unit) -> unit
val fold : init:'a -> check_access: ('b -> ([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (unit -> unit) option) Fieldslib.Field.t_with_perm -> 'c) -> job_pool: ('d -> ([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (Execution_context.t, Obj.t -> unit, Obj.t) Tuple_pool.Slots.t3 Tuple_pool.t) Fieldslib.Field.t_with_perm -> 'e) -> normal_priority_jobs: ('f -> ([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Async_kernel__.Types.Job_queue.t) Fieldslib.Field.t_with_perm -> 'g) -> low_priority_jobs: ('h -> ([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Async_kernel__.Types.Job_queue.t) Fieldslib.Field.t_with_perm -> 'i) -> very_low_priority_workers: ('j -> ([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Async_kernel__.Types.Very_low_priority_worker.t Core.Deque.t) Fieldslib.Field.t_with_perm -> 'k) -> main_execution_context: ('l -> ([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Execution_context.t) Fieldslib.Field.t_with_perm -> 'm) -> current_execution_context: ('n -> ([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Execution_context.t) Fieldslib.Field.t_with_perm -> 'o) -> uncaught_exn: ('p -> ([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (Core.Exn.t * Core.Sexp.t) option) Fieldslib.Field.t_with_perm -> 'q) -> cycle_count: ('r -> ([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, int) Fieldslib.Field.t_with_perm -> 's) -> cycle_start: ('t -> ([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Core.Time_ns.t) Fieldslib.Field.t_with_perm -> 'u) -> in_cycle: ('v -> ([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, bool) Fieldslib.Field.t_with_perm -> 'w) -> run_every_cycle_start: ('x -> ([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (unit -> unit) list) Fieldslib.Field.t_with_perm -> 'y) -> run_every_cycle_start_state: ('z -> ([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (Async_kernel__.Types.Cycle_hook_handle.t, unit -> unit) Core.Hashtbl.t) Fieldslib.Field.t_with_perm -> 'a1) -> run_every_cycle_end: ('b1 -> ([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (unit -> unit) list) Fieldslib.Field.t_with_perm -> 'c1) -> run_every_cycle_end_state: ('d1 -> ([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (Async_kernel__.Types.Cycle_hook_handle.t, unit -> unit) Core.Hashtbl.t) Fieldslib.Field.t_with_perm -> 'e1) -> last_cycle_time: ('f1 -> ([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Core.Core_private.Time_ns_alternate_sexp.Span.t) Fieldslib.Field.t_with_perm -> 'g1) -> last_cycle_num_jobs: ('h1 -> ([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, int) Fieldslib.Field.t_with_perm -> 'i1) -> total_cycle_time: ('j1 -> ([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Core.Core_private.Time_ns_alternate_sexp.Span.t) Fieldslib.Field.t_with_perm -> 'k1) -> time_source: ('l1 -> ([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Core.read_write Async_kernel__.Types.Time_source.t1) Fieldslib.Field.t_with_perm -> 'm1) -> external_jobs: ('n1 -> ([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Async_kernel__.Types.External_job.t Thread_safe_queue.t) Fieldslib.Field.t_with_perm -> 'o1) -> thread_safe_external_job_hook: ('p1 -> ([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, unit -> unit) Fieldslib.Field.t_with_perm -> 'q1) -> job_queued_hook: ('r1 -> ([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (Priority.t -> unit) option) Fieldslib.Field.t_with_perm -> 's1) -> event_added_hook: ('t1 -> ([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (Core.Time_ns.t -> unit) option) Fieldslib.Field.t_with_perm -> 'u1) -> yield: ('v1 -> ([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (unit, Core.read_write) Async_kernel__.Types.Bvar.t) Fieldslib.Field.t_with_perm -> 'w1) -> yield_until_no_jobs_remain: ('x1 -> ([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (unit, Core.read_write) Async_kernel__.Types.Bvar.t) Fieldslib.Field.t_with_perm -> 'y1) -> check_invariants: ('z1 -> ([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, bool) Fieldslib.Field.t_with_perm -> 'a2) -> max_num_jobs_per_priority_per_cycle: ('b2 -> ([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Async_kernel_config.Max_num_jobs_per_priority_per_cycle.t) Fieldslib.Field.t_with_perm -> 'c2) -> record_backtraces: ('d2 -> ([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, bool) Fieldslib.Field.t_with_perm -> 'e2) -> 'f2
val map_poly : ([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, 'a) Fieldslib.Field.user -> 'b list
val for_all : check_access: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (unit -> unit) option) Fieldslib.Field.t_with_perm -> bool) -> job_pool: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (Execution_context.t, Obj.t -> unit, Obj.t) Tuple_pool.Slots.t3 Tuple_pool.t) Fieldslib.Field.t_with_perm -> bool) -> normal_priority_jobs: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Async_kernel__.Types.Job_queue.t) Fieldslib.Field.t_with_perm -> bool) -> low_priority_jobs: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Async_kernel__.Types.Job_queue.t) Fieldslib.Field.t_with_perm -> bool) -> very_low_priority_workers: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Async_kernel__.Types.Very_low_priority_worker.t Core.Deque.t) Fieldslib.Field.t_with_perm -> bool) -> main_execution_context: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Execution_context.t) Fieldslib.Field.t_with_perm -> bool) -> current_execution_context: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Execution_context.t) Fieldslib.Field.t_with_perm -> bool) -> uncaught_exn: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (Core.Exn.t * Core.Sexp.t) option) Fieldslib.Field.t_with_perm -> bool) -> cycle_count: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, int) Fieldslib.Field.t_with_perm -> bool) -> cycle_start: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Core.Time_ns.t) Fieldslib.Field.t_with_perm -> bool) -> in_cycle: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, bool) Fieldslib.Field.t_with_perm -> bool) -> run_every_cycle_start: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (unit -> unit) list) Fieldslib.Field.t_with_perm -> bool) -> run_every_cycle_start_state: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (Async_kernel__.Types.Cycle_hook_handle.t, unit -> unit) Core.Hashtbl.t) Fieldslib.Field.t_with_perm -> bool) -> run_every_cycle_end: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (unit -> unit) list) Fieldslib.Field.t_with_perm -> bool) -> run_every_cycle_end_state: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (Async_kernel__.Types.Cycle_hook_handle.t, unit -> unit) Core.Hashtbl.t) Fieldslib.Field.t_with_perm -> bool) -> last_cycle_time: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Core.Core_private.Time_ns_alternate_sexp.Span.t) Fieldslib.Field.t_with_perm -> bool) -> last_cycle_num_jobs: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, int) Fieldslib.Field.t_with_perm -> bool) -> total_cycle_time: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Core.Core_private.Time_ns_alternate_sexp.Span.t) Fieldslib.Field.t_with_perm -> bool) -> time_source: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Core.read_write Async_kernel__.Types.Time_source.t1) Fieldslib.Field.t_with_perm -> bool) -> external_jobs: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Async_kernel__.Types.External_job.t Thread_safe_queue.t) Fieldslib.Field.t_with_perm -> bool) -> thread_safe_external_job_hook: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, unit -> unit) Fieldslib.Field.t_with_perm -> bool) -> job_queued_hook: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (Priority.t -> unit) option) Fieldslib.Field.t_with_perm -> bool) -> event_added_hook: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (Core.Time_ns.t -> unit) option) Fieldslib.Field.t_with_perm -> bool) -> yield: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (unit, Core.read_write) Async_kernel__.Types.Bvar.t) Fieldslib.Field.t_with_perm -> bool) -> yield_until_no_jobs_remain: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (unit, Core.read_write) Async_kernel__.Types.Bvar.t) Fieldslib.Field.t_with_perm -> bool) -> check_invariants: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, bool) Fieldslib.Field.t_with_perm -> bool) -> max_num_jobs_per_priority_per_cycle: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Async_kernel_config.Max_num_jobs_per_priority_per_cycle.t) Fieldslib.Field.t_with_perm -> bool) -> record_backtraces: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, bool) Fieldslib.Field.t_with_perm -> bool) -> bool
val exists : check_access: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (unit -> unit) option) Fieldslib.Field.t_with_perm -> bool) -> job_pool: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (Execution_context.t, Obj.t -> unit, Obj.t) Tuple_pool.Slots.t3 Tuple_pool.t) Fieldslib.Field.t_with_perm -> bool) -> normal_priority_jobs: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Async_kernel__.Types.Job_queue.t) Fieldslib.Field.t_with_perm -> bool) -> low_priority_jobs: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Async_kernel__.Types.Job_queue.t) Fieldslib.Field.t_with_perm -> bool) -> very_low_priority_workers: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Async_kernel__.Types.Very_low_priority_worker.t Core.Deque.t) Fieldslib.Field.t_with_perm -> bool) -> main_execution_context: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Execution_context.t) Fieldslib.Field.t_with_perm -> bool) -> current_execution_context: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Execution_context.t) Fieldslib.Field.t_with_perm -> bool) -> uncaught_exn: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (Core.Exn.t * Core.Sexp.t) option) Fieldslib.Field.t_with_perm -> bool) -> cycle_count: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, int) Fieldslib.Field.t_with_perm -> bool) -> cycle_start: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Core.Time_ns.t) Fieldslib.Field.t_with_perm -> bool) -> in_cycle: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, bool) Fieldslib.Field.t_with_perm -> bool) -> run_every_cycle_start: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (unit -> unit) list) Fieldslib.Field.t_with_perm -> bool) -> run_every_cycle_start_state: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (Async_kernel__.Types.Cycle_hook_handle.t, unit -> unit) Core.Hashtbl.t) Fieldslib.Field.t_with_perm -> bool) -> run_every_cycle_end: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (unit -> unit) list) Fieldslib.Field.t_with_perm -> bool) -> run_every_cycle_end_state: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (Async_kernel__.Types.Cycle_hook_handle.t, unit -> unit) Core.Hashtbl.t) Fieldslib.Field.t_with_perm -> bool) -> last_cycle_time: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Core.Core_private.Time_ns_alternate_sexp.Span.t) Fieldslib.Field.t_with_perm -> bool) -> last_cycle_num_jobs: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, int) Fieldslib.Field.t_with_perm -> bool) -> total_cycle_time: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Core.Core_private.Time_ns_alternate_sexp.Span.t) Fieldslib.Field.t_with_perm -> bool) -> time_source: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Core.read_write Async_kernel__.Types.Time_source.t1) Fieldslib.Field.t_with_perm -> bool) -> external_jobs: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Async_kernel__.Types.External_job.t Thread_safe_queue.t) Fieldslib.Field.t_with_perm -> bool) -> thread_safe_external_job_hook: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, unit -> unit) Fieldslib.Field.t_with_perm -> bool) -> job_queued_hook: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (Priority.t -> unit) option) Fieldslib.Field.t_with_perm -> bool) -> event_added_hook: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (Core.Time_ns.t -> unit) option) Fieldslib.Field.t_with_perm -> bool) -> yield: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (unit, Core.read_write) Async_kernel__.Types.Bvar.t) Fieldslib.Field.t_with_perm -> bool) -> yield_until_no_jobs_remain: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (unit, Core.read_write) Async_kernel__.Types.Bvar.t) Fieldslib.Field.t_with_perm -> bool) -> check_invariants: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, bool) Fieldslib.Field.t_with_perm -> bool) -> max_num_jobs_per_priority_per_cycle: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Async_kernel_config.Max_num_jobs_per_priority_per_cycle.t) Fieldslib.Field.t_with_perm -> bool) -> record_backtraces: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, bool) Fieldslib.Field.t_with_perm -> bool) -> bool
val to_list : check_access: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (unit -> unit) option) Fieldslib.Field.t_with_perm -> 'a) -> job_pool: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (Execution_context.t, Obj.t -> unit, Obj.t) Tuple_pool.Slots.t3 Tuple_pool.t) Fieldslib.Field.t_with_perm -> 'b) -> normal_priority_jobs: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Async_kernel__.Types.Job_queue.t) Fieldslib.Field.t_with_perm -> 'c) -> low_priority_jobs: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Async_kernel__.Types.Job_queue.t) Fieldslib.Field.t_with_perm -> 'd) -> very_low_priority_workers: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Async_kernel__.Types.Very_low_priority_worker.t Core.Deque.t) Fieldslib.Field.t_with_perm -> 'e) -> main_execution_context: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Execution_context.t) Fieldslib.Field.t_with_perm -> 'f) -> current_execution_context: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Execution_context.t) Fieldslib.Field.t_with_perm -> 'g) -> uncaught_exn: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (Core.Exn.t * Core.Sexp.t) option) Fieldslib.Field.t_with_perm -> 'h) -> cycle_count: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, int) Fieldslib.Field.t_with_perm -> 'i) -> cycle_start: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Core.Time_ns.t) Fieldslib.Field.t_with_perm -> 'j) -> in_cycle: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, bool) Fieldslib.Field.t_with_perm -> 'k) -> run_every_cycle_start: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (unit -> unit) list) Fieldslib.Field.t_with_perm -> 'l) -> run_every_cycle_start_state: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (Async_kernel__.Types.Cycle_hook_handle.t, unit -> unit) Core.Hashtbl.t) Fieldslib.Field.t_with_perm -> 'm) -> run_every_cycle_end: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (unit -> unit) list) Fieldslib.Field.t_with_perm -> 'n) -> run_every_cycle_end_state: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (Async_kernel__.Types.Cycle_hook_handle.t, unit -> unit) Core.Hashtbl.t) Fieldslib.Field.t_with_perm -> 'o) -> last_cycle_time: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Core.Core_private.Time_ns_alternate_sexp.Span.t) Fieldslib.Field.t_with_perm -> 'p) -> last_cycle_num_jobs: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, int) Fieldslib.Field.t_with_perm -> 'q) -> total_cycle_time: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Core.Core_private.Time_ns_alternate_sexp.Span.t) Fieldslib.Field.t_with_perm -> 'r) -> time_source: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Core.read_write Async_kernel__.Types.Time_source.t1) Fieldslib.Field.t_with_perm -> 's) -> external_jobs: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Async_kernel__.Types.External_job.t Thread_safe_queue.t) Fieldslib.Field.t_with_perm -> 't) -> thread_safe_external_job_hook: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, unit -> unit) Fieldslib.Field.t_with_perm -> 'u) -> job_queued_hook: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (Priority.t -> unit) option) Fieldslib.Field.t_with_perm -> 'v) -> event_added_hook: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (Core.Time_ns.t -> unit) option) Fieldslib.Field.t_with_perm -> 'w) -> yield: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (unit, Core.read_write) Async_kernel__.Types.Bvar.t) Fieldslib.Field.t_with_perm -> 'x) -> yield_until_no_jobs_remain: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, (unit, Core.read_write) Async_kernel__.Types.Bvar.t) Fieldslib.Field.t_with_perm -> 'y) -> check_invariants: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, bool) Fieldslib.Field.t_with_perm -> 'z) -> max_num_jobs_per_priority_per_cycle: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, Async_kernel_config.Max_num_jobs_per_priority_per_cycle.t) Fieldslib.Field.t_with_perm -> 'a1) -> record_backtraces: (([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, bool) Fieldslib.Field.t_with_perm -> 'b1) -> 'c1 list
module Direct : sig ... end
OCaml

Innovation. Community. Security.

GitHub Discord Twitter Peertube RSS
About
Changelog Releases Industrial Users Academic Users Why OCaml
Ecosystem
Packages Community Events OCaml Planet Jobs
Resources
Install OCaml Get Started Platform Tools Language Manual Standard Library API Books Exercises Papers OCaml Playground Logo
Policies
Carbon Footprint Governance Privacy Code of Conduct