package async_kernel

  1. Overview
  2. Docs
package async_kernel
Legend:
Library
Module
Module type
Parameter
Class
Class type
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) array) 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) array) 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, Stdlib.Obj.t -> unit, Stdlib.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 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, Stdlib.Obj.t -> unit, Stdlib.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) array) 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) array) 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
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