Module `Async_kernel_scheduler.Private`Source

Internal to Async -- see Async_unix.Scheduler for the public API.

Sourcemodule Deferred : sig ... end

Sourcetype t

Sourceval sexp_of_t : t -> Sexplib0.Sexp.t

Sourceval t : unit -> t

include Core.Invariant.S with type t := t

Sourceval invariant : t -> unit

Sourceval current_execution_context : t -> Execution_context.t

Sourceval with_execution_context : t -> Execution_context.t -> f:(unit -> 'a) -> 'a

Source

val with_execution_context1 : 
  t ->
  Execution_context.t ->
  f:('a -> 'b) ->
  'a ->
  'b

Sourceval set_execution_context : t -> Execution_context.t -> unit

Sourceval enqueue : t -> Execution_context.t -> ('a -> unit) -> 'a -> unit

Source

val create_job : 
  t ->
  Execution_context.t ->
  ('a -> unit) ->
  'a ->
  (Async_kernel__.Types.Execution_context.t, Obj.t -> unit, Obj.t)
    Tuple_pool.Slots.t3
    Tuple_pool.Pointer.t

Source

val enqueue_job : 
  t ->
  (Async_kernel__.Types.Execution_context.t, Obj.t -> unit, Obj.t)
    Tuple_pool.Slots.t3
    Tuple_pool.Pointer.t ->
  free_job:bool ->
  unit

Source

val free_job : 
  t ->
  (Async_kernel__.Types.Execution_context.t, Obj.t -> unit, Obj.t)
    Tuple_pool.Slots.t3
    Tuple_pool.Pointer.t ->
  unit

Sourceval main_execution_context : Execution_context.t

Sourceval cycle_start : t -> Core.Time_ns.t

Sourceval run_cycle : t -> unit

Sourceval run_cycles_until_no_jobs_remain : unit -> unit

Sourceval has_upcoming_event : t -> bool

Sourceval next_upcoming_event : t -> Core.Time_ns.t option

Sourceval next_upcoming_event_exn : t -> Core.Time_ns.t

Sourceval event_precision : t -> Core.Core_private.Time_ns_alternate_sexp.Span.t

Sourceval uncaught_exn : t -> Core.Error.t option

Sourceval uncaught_exn_unwrapped : t -> (Core.Exn.t * Core.Sexp.t) option

Sourceval num_pending_jobs : t -> int

Sourceval num_jobs_run : t -> int

Sourceval last_cycle_num_jobs : t -> int

Source

val map_cycle_times : 
  t ->
  f:(Core.Core_private.Time_ns_alternate_sexp.Span.t -> 'a) ->
  'a Tail.Stream.t

Sourceval cycle_num_jobs : t -> int Tail.Stream.t

Sourceval cycle_count : t -> int

Sourceval total_cycle_time : t -> Core.Core_private.Time_ns_alternate_sexp.Span.t

Sourceval max_num_jobs_per_priority_per_cycle : t -> int

Sourceval set_max_num_jobs_per_priority_per_cycle : t -> int -> unit

Sourceval set_check_access : t -> (unit -> unit) option -> unit

Sourceval check_access : t -> unit

Sourceval check_invariants : t -> bool

Sourceval set_check_invariants : t -> bool -> unit

Sourceval recording_backtraces : t -> bool

Sourceval set_record_backtraces : t -> bool -> unit

Sourceval run_every_cycle_start : t -> f:(unit -> unit) -> unit

Sourceval run_every_cycle_end : t -> f:(unit -> unit) -> unit

Source

val add_every_cycle_start_hook : 
  t ->
  f:(unit -> unit) ->
  Async_kernel__.Types.Cycle_hook_handle.t

Source

val add_every_cycle_end_hook : 
  t ->
  f:(unit -> unit) ->
  Async_kernel__.Types.Cycle_hook_handle.t

Source

val remove_every_cycle_start_hook_exn : 
  t ->
  Async_kernel__.Types.Cycle_hook_handle.t ->
  unit

Source

val remove_every_cycle_end_hook_exn : 
  t ->
  Async_kernel__.Types.Cycle_hook_handle.t ->
  unit

Sourceval last_cycle_time : t -> Core.Core_private.Time_ns_alternate_sexp.Span.t

Source

val long_cycles : 
  t ->
  at_least:Core.Core_private.Time_ns_alternate_sexp.Span.t ->
  Core.Core_private.Time_ns_alternate_sexp.Span.t Tail.Stream.t

Sourceval can_run_a_job : t -> bool

Sourceval create_alarm : t -> (unit -> unit) -> Core.Gc.Expert.Alarm.t

Source

val add_finalizer : 
  t ->
  'a Core.Heap_block.t ->
  ('a Core.Heap_block.t -> unit) ->
  unit

Sourceval add_finalizer_exn : t -> 'a -> ('a -> unit) -> unit

Sourceval add_finalizer_last : t -> 'a Core.Heap_block.t -> (unit -> unit) -> unit

Sourceval add_finalizer_last_exn : t -> 'a -> (unit -> unit) -> unit

Sourceval set_thread_safe_external_job_hook : t -> (unit -> unit) -> unit

Sourceval set_job_queued_hook : t -> (Priority.t -> unit) -> unit

Sourceval set_event_added_hook : t -> (Core.Time_ns.t -> unit) -> unit

Sourceval backtrace_of_first_job : t -> Core.Backtrace.t option

Source

val thread_safe_enqueue_external_job : 
  t ->
  Execution_context.t ->
  ('a -> unit) ->
  'a ->
  unit

Sourceval force_current_cycle_to_end : t -> unit

type 'a with_options := ?monitor:Monitor.t -> ?priority:Priority.t -> 'a

Sourceval within' : ((unit -> 'a Deferred.t) -> 'a Deferred.t) with_options

Sourceval within : ((unit -> unit) -> unit) with_options

Sourceval within_v : ((unit -> 'a) -> 'a option) with_options

Sourceval schedule' : ((unit -> 'a Deferred.t) -> 'a Deferred.t) with_options

Sourceval schedule : ((unit -> unit) -> unit) with_options

Sourceval preserve_execution_context : ('a -> unit) -> ('a -> unit) Core.Staged.t

Source

val preserve_execution_context' : 
  ('a -> 'b Deferred.t) ->
  ('a -> 'b Deferred.t) Core.Staged.t

Source

val within_context : 
  Execution_context.t ->
  (unit -> 'a) ->
  ('a, unit) Core.Result.t

Sourceval find_local : 'a Core.Univ_map.Key.t -> 'a option

Sourceval with_local : 'a Core.Univ_map.Key.t -> 'a option -> f:(unit -> 'b) -> 'b

Sourceval make_async_unusable : unit -> unit

Sourceval reset_in_forked_process : unit -> unit

Sourceval yield : t -> unit Deferred.t

Sourceval yield_every : n:int -> (t -> unit Deferred.t) Core.Staged.t

Source

val yield_until_no_jobs_remain : 
  ?may_return_immediately:bool ->
  t ->
  unit Deferred.t

Sourcemodule Very_low_priority_work : sig ... end

package async_kernel

Module Async_kernel_scheduler.PrivateSource

Module `Async_kernel_scheduler.Private`Source