async_kernel v0.17.0 · OCaml Package

async_kernel

val record_backtraces : 
  ([< `Read | `Set_and_create ], t, bool) Fieldslib.Field.t_with_perm

val max_num_jobs_per_priority_per_cycle : 
  ([< `Read | `Set_and_create ],
    t,
    Async_kernel_config.Max_num_jobs_per_priority_per_cycle.t)
    Fieldslib.Field.t_with_perm

val check_invariants : 
  ([< `Read | `Set_and_create ], t, bool) Fieldslib.Field.t_with_perm

val yield_until_no_jobs_remain : 
  ([< `Read | `Set_and_create ],
    t,
    (unit, Core.read_write) Async_kernel__.Types.Bvar.t)
    Fieldslib.Field.t_with_perm

val yield : 
  ([< `Read | `Set_and_create ],
    t,
    (unit, Core.read_write) Async_kernel__.Types.Bvar.t)
    Fieldslib.Field.t_with_perm

val event_added_hook : 
  ([< `Read | `Set_and_create ], t, (Core.Time_ns.t -> unit) option)
    Fieldslib.Field.t_with_perm

val job_queued_hook : 
  ([< `Read | `Set_and_create ], t, (Priority.t -> unit) option)
    Fieldslib.Field.t_with_perm

val thread_safe_external_job_hook : 
  ([< `Read | `Set_and_create ], t, unit -> unit) Fieldslib.Field.t_with_perm

val external_jobs : 
  ([< `Read | `Set_and_create ],
    t,
    Async_kernel__.Types.External_job.t Thread_safe_queue.t)
    Fieldslib.Field.t_with_perm

val time_source : 
  ([< `Read | `Set_and_create ],
    t,
    Core.read_write Synchronous_time_source.T1.t)
    Fieldslib.Field.t_with_perm

val total_cycle_time : 
  ([< `Read | `Set_and_create ],
    t,
    Core.Core_private.Time_ns_alternate_sexp.Span.t)
    Fieldslib.Field.t_with_perm

val last_cycle_num_jobs : 
  ([< `Read | `Set_and_create ], t, int) Fieldslib.Field.t_with_perm

val last_cycle_time : 
  ([< `Read | `Set_and_create ],
    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 ],
    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 ], t, (unit -> unit) array)
    Fieldslib.Field.t_with_perm

val run_every_cycle_start_state : 
  ([< `Read | `Set_and_create ],
    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 ], t, (unit -> unit) array)
    Fieldslib.Field.t_with_perm

val in_cycle : 
  ([< `Read | `Set_and_create ], t, bool) Fieldslib.Field.t_with_perm

val cycle_start : 
  ([< `Read | `Set_and_create ], t, Core.Time_ns.t) Fieldslib.Field.t_with_perm

val cycle_count : 
  ([< `Read | `Set_and_create ], t, int) Fieldslib.Field.t_with_perm

val uncaught_exn : 
  ([< `Read | `Set_and_create ], t, (Core.Exn.t * Core.Sexp.t) option)
    Fieldslib.Field.t_with_perm

val current_execution_context : 
  ([< `Read | `Set_and_create ], t, Execution_context.t)
    Fieldslib.Field.t_with_perm

val main_execution_context : 
  ([< `Read | `Set_and_create ], t, Execution_context.t)
    Fieldslib.Field.t_with_perm

val very_low_priority_workers : 
  ([< `Read | `Set_and_create ], t, Very_low_priority_worker.t Core.Deque.t)
    Fieldslib.Field.t_with_perm

val low_priority_jobs : 
  ([< `Read | `Set_and_create ], t, Async_kernel__.Types.Job_queue.t)
    Fieldslib.Field.t_with_perm

val normal_priority_jobs : 
  ([< `Read | `Set_and_create ], t, Async_kernel__.Types.Job_queue.t)
    Fieldslib.Field.t_with_perm

val job_pool : 
  ([< `Read | `Set_and_create ],
    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 ], t, (unit -> unit) option)
    Fieldslib.Field.t_with_perm

val iter : 
  check_access:
    (([< `Read | `Set_and_create ], t, (unit -> unit) option)
       Fieldslib.Field.t_with_perm ->
      unit) ->
  job_pool:
    (([< `Read | `Set_and_create ],
       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 ], t, Async_kernel__.Types.Job_queue.t)
       Fieldslib.Field.t_with_perm ->
      unit) ->
  low_priority_jobs:
    (([< `Read | `Set_and_create ], t, Async_kernel__.Types.Job_queue.t)
       Fieldslib.Field.t_with_perm ->
      unit) ->
  very_low_priority_workers:
    (([< `Read | `Set_and_create ], t, Very_low_priority_worker.t Core.Deque.t)
       Fieldslib.Field.t_with_perm ->
      unit) ->
  main_execution_context:
    (([< `Read | `Set_and_create ], t, Execution_context.t)
       Fieldslib.Field.t_with_perm ->
      unit) ->
  current_execution_context:
    (([< `Read | `Set_and_create ], t, Execution_context.t)
       Fieldslib.Field.t_with_perm ->
      unit) ->
  uncaught_exn:
    (([< `Read | `Set_and_create ], t, (Core.Exn.t * Core.Sexp.t) option)
       Fieldslib.Field.t_with_perm ->
      unit) ->
  cycle_count:
    (([< `Read | `Set_and_create ], t, int) Fieldslib.Field.t_with_perm ->
      unit) ->
  cycle_start:
    (([< `Read | `Set_and_create ], t, Core.Time_ns.t)
       Fieldslib.Field.t_with_perm ->
      unit) ->
  in_cycle:
    (([< `Read | `Set_and_create ], t, bool) Fieldslib.Field.t_with_perm ->
      unit) ->
  run_every_cycle_start:
    (([< `Read | `Set_and_create ], t, (unit -> unit) array)
       Fieldslib.Field.t_with_perm ->
      unit) ->
  run_every_cycle_start_state:
    (([< `Read | `Set_and_create ],
       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 ], t, (unit -> unit) array)
       Fieldslib.Field.t_with_perm ->
      unit) ->
  run_every_cycle_end_state:
    (([< `Read | `Set_and_create ],
       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 ],
       t,
       Core.Core_private.Time_ns_alternate_sexp.Span.t)
       Fieldslib.Field.t_with_perm ->
      unit) ->
  last_cycle_num_jobs:
    (([< `Read | `Set_and_create ], t, int) Fieldslib.Field.t_with_perm ->
      unit) ->
  total_cycle_time:
    (([< `Read | `Set_and_create ],
       t,
       Core.Core_private.Time_ns_alternate_sexp.Span.t)
       Fieldslib.Field.t_with_perm ->
      unit) ->
  time_source:
    (([< `Read | `Set_and_create ],
       t,
       Core.read_write Synchronous_time_source.T1.t)
       Fieldslib.Field.t_with_perm ->
      unit) ->
  external_jobs:
    (([< `Read | `Set_and_create ],
       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 ], t, unit -> unit)
       Fieldslib.Field.t_with_perm ->
      unit) ->
  job_queued_hook:
    (([< `Read | `Set_and_create ], t, (Priority.t -> unit) option)
       Fieldslib.Field.t_with_perm ->
      unit) ->
  event_added_hook:
    (([< `Read | `Set_and_create ], t, (Core.Time_ns.t -> unit) option)
       Fieldslib.Field.t_with_perm ->
      unit) ->
  yield:
    (([< `Read | `Set_and_create ],
       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 ],
       t,
       (unit, Core.read_write) Async_kernel__.Types.Bvar.t)
       Fieldslib.Field.t_with_perm ->
      unit) ->
  check_invariants:
    (([< `Read | `Set_and_create ], t, bool) Fieldslib.Field.t_with_perm ->
      unit) ->
  max_num_jobs_per_priority_per_cycle:
    (([< `Read | `Set_and_create ],
       t,
       Async_kernel_config.Max_num_jobs_per_priority_per_cycle.t)
       Fieldslib.Field.t_with_perm ->
      unit) ->
  record_backtraces:
    (([< `Read | `Set_and_create ], t, bool) Fieldslib.Field.t_with_perm ->
      unit) ->
  unit

package async_kernel