sig
  val go : ?raise_unhandled_exn:bool -> unit -> Core.Std.never_returns
  val go_main :
    ?raise_unhandled_exn:bool ->
    main:(unit -> unit) -> unit -> Core.Std.never_returns
  type 'a with_options =
      ?work_group:Work_group.t ->
      ?monitor:Import.Monitor.t -> ?priority:Import.Priority.t -> 'a
  val within_context :
    Import.Execution_context.t ->
    (unit -> 'a) -> ('a, unit) Core.Std.Result.t
  val within' :
    ((unit -> 'a Import.Deferred.t) -> 'a Import.Deferred.t) with_options
  val within : ((unit -> unit) -> unit) with_options
  val within_v : ((unit -> 'a) -> 'a option) with_options
  val schedule' :
    ((unit -> 'a Import.Deferred.t) -> 'a Import.Deferred.t) with_options
  val schedule : ((unit -> unit) -> unit) with_options
  val cycle_start : unit -> Core.Std.Time.t
  val cycle_times : unit -> Core.Std.Time.Span.t Import.Stream.t
  val report_long_cycle_times : ?cutoff:Core.Std.Time.Span.t -> unit -> unit
  val cycle_count : unit -> int
  val is_running : unit -> bool
  val set_max_num_jobs_per_priority_per_cycle : int -> unit
  val is_ready_to_initialize : unit -> bool
  val reset_in_forked_process : unit -> unit
  val ounit_tests : unit -> OUnit.test
end