package async_kernel
Module Scheduler.FieldsSource
Source
val record_backtraces :
([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, bool)
Fieldslib.Field.t_with_permSource
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_permSource
val check_invariants :
([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, bool)
Fieldslib.Field.t_with_permSource
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_permSource
val yield :
([< `Read | `Set_and_create ],
Async_kernel__.Types.Scheduler.t,
(unit, Core.read_write) Async_kernel__.Types.Bvar.t)
Fieldslib.Field.t_with_permSource
val event_added_hook :
([< `Read | `Set_and_create ],
Async_kernel__.Types.Scheduler.t,
(Core.Time_ns.t -> unit) option)
Fieldslib.Field.t_with_permSource
val job_queued_hook :
([< `Read | `Set_and_create ],
Async_kernel__.Types.Scheduler.t,
(Priority.t -> unit) option)
Fieldslib.Field.t_with_permSource
val thread_safe_external_job_hook :
([< `Read | `Set_and_create ],
Async_kernel__.Types.Scheduler.t,
unit ->
unit)
Fieldslib.Field.t_with_permSource
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_permSource
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_permSource
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_permSource
val last_cycle_num_jobs :
([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, int)
Fieldslib.Field.t_with_permSource
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_permSource
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_permSource
val run_every_cycle_end :
([< `Read | `Set_and_create ],
Async_kernel__.Types.Scheduler.t,
(unit -> unit) array)
Fieldslib.Field.t_with_permSource
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_permSource
val run_every_cycle_start :
([< `Read | `Set_and_create ],
Async_kernel__.Types.Scheduler.t,
(unit -> unit) array)
Fieldslib.Field.t_with_permSource
val in_cycle :
([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, bool)
Fieldslib.Field.t_with_permSource
val cycle_start :
([< `Read | `Set_and_create ],
Async_kernel__.Types.Scheduler.t,
Core.Time_ns.t)
Fieldslib.Field.t_with_permSource
val cycle_count :
([< `Read | `Set_and_create ], Async_kernel__.Types.Scheduler.t, int)
Fieldslib.Field.t_with_permSource
val uncaught_exn :
([< `Read | `Set_and_create ],
Async_kernel__.Types.Scheduler.t,
(Core.Exn.t * Core.Sexp.t) option)
Fieldslib.Field.t_with_permSource
val current_execution_context :
([< `Read | `Set_and_create ],
Async_kernel__.Types.Scheduler.t,
Execution_context.t)
Fieldslib.Field.t_with_permSource
val main_execution_context :
([< `Read | `Set_and_create ],
Async_kernel__.Types.Scheduler.t,
Execution_context.t)
Fieldslib.Field.t_with_permSource
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_permSource
val low_priority_jobs :
([< `Read | `Set_and_create ],
Async_kernel__.Types.Scheduler.t,
Async_kernel__.Types.Job_queue.t)
Fieldslib.Field.t_with_permSource
val normal_priority_jobs :
([< `Read | `Set_and_create ],
Async_kernel__.Types.Scheduler.t,
Async_kernel__.Types.Job_queue.t)
Fieldslib.Field.t_with_permSource
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_permSource
val check_access :
([< `Read | `Set_and_create ],
Async_kernel__.Types.Scheduler.t,
(unit -> unit) option)
Fieldslib.Field.t_with_permSource
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) 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