package async_kernel

  1. Overview
  2. Docs
package async_kernel
Legend:
Page
Library
Module
Module type
Parameter
Class
Class type
Source

Module Async_kernel_scheduler.PrivateSource

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
Sourceval 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
Sourceval 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
Sourceval 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
Sourceval 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 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
Sourceval cycle_num_jobs : t -> int Tail.Stream.t
Sourceval cycle_count : t -> int
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
Sourceval add_every_cycle_start_hook : t -> f:(unit -> unit) -> Async_kernel__.Types.Cycle_hook_handle.t
Sourceval add_every_cycle_end_hook : t -> f:(unit -> unit) -> Async_kernel__.Types.Cycle_hook_handle.t
Sourceval remove_every_cycle_start_hook_exn : t -> Async_kernel__.Types.Cycle_hook_handle.t -> unit
Sourceval remove_every_cycle_end_hook_exn : t -> Async_kernel__.Types.Cycle_hook_handle.t -> unit
Sourceval can_run_a_job : t -> bool
Sourceval create_alarm : t -> (unit -> unit) -> Core.Gc.Expert.Alarm.t
Sourceval 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
Sourceval 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
Sourceval preserve_execution_context' : ('a -> 'b Deferred.t) -> ('a -> 'b Deferred.t) Core.Staged.t
Sourceval 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
Sourceval yield_until_no_jobs_remain : ?may_return_immediately:bool -> t -> unit Deferred.t
Sourcemodule Very_low_priority_work : 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