async_kernel v0.9.0 · OCaml Package

async_kernel

module T1 : sig ... end

module Read_write : sig ... end

type t = Core_kernel.read T1.t

include sig ... end

val sexp_of_t : t -> Sexplib.Sexp.t

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

val invariant : t -> unit

val read_only : [> Core_kernel.read ] T1.t -> t

type callback = unit -> unit

val create : 
  ?timing_wheel_config:Core_kernel.Timing_wheel_ns.Config.t ->
  ?wrap_callback:(callback -> callback Core_kernel.Staged.t) ->
  now:Base__.Int63_backends.Dynamic.t ->
  unit ->
  Core_kernel.read_write T1.t

create ~now () creates a new time source. The default timing_wheel_config has 100 microsecond precision, with levels of >1s, >1m, >1h, >1d. wrap_callback, if supplied, will be applied to each callback that is added.

val alarm_precision : 
  [> Core_kernel.read ] T1.t ->
  Core_kernel.Core_kernel_private.Time_ns_alternate_sexp.Span.t

val is_wall_clock : [> Core_kernel.read ] T1.t -> bool

is_wall_clock reports whether this time source represents 'wall clock' time, or some alternate source of time.

val now : [> Core_kernel.read ] T1.t -> Base__.Int63_backends.Dynamic.t

The behavior of now is special for wall_clock (); it always calls Time_ns.now (), so it can return times that the time source has not yet been advanced to.

val advance_by_alarms : 
  [> Core_kernel.write ] T1.t ->
  to_:Base__.Int63_backends.Dynamic.t ->
  unit Core_kernel.Or_error.t

advance_by_alarms t ~to_ advances t's time to to_, running callbacks for all alarms in t whose at <= to_. If to_ <= now t, then now t does not change (and in particular does not go backward), but alarms with at <= to_ may still may fire.

val run_at : 
  [> Core_kernel.read ] T1.t ->
  Base__.Int63_backends.Dynamic.t ->
  callback ->
  unit

run_at t at f schedules an alarm that will run f during the next subsequent advance_by_alarms t ~to_ that causes now t >= at. If at <= now t, then f will to run at the next call to advance_by_alarms. f is allowed to do all Synchronous_time_source operations except for advance_by_alarms (because f is already running during advance_by_alarms. Adding alarms is not zero-alloc and the underlying events live in the OCaml heap.

val run_after : 
  [> Core_kernel.read ] T1.t ->
  Core_kernel.Core_kernel_private.Time_ns_alternate_sexp.Span.t ->
  callback ->
  unit

run_after t span f is run_at t (now t + span) f.

val run_at_intervals : 
  [> Core_kernel.read ] T1.t ->
  Core_kernel.Core_kernel_private.Time_ns_alternate_sexp.Span.t ->
  callback ->
  unit

run_at_intervals t span f causes f to run at intervals now t + k * span, for k = 0, 1, 2, etc. run_at_intervals raises if span < alarm_precision t.

module Event : sig ... end

val default_timing_wheel_config : Core_kernel.Timing_wheel_ns.Config.t

val wall_clock : unit -> t

A time source with now t given by wall-clock time (i.e. Time_ns.now), and automatically advanced at the start of each Async cycle.

package async_kernel