simon/moonpool
1
0
Fork 0
mirror of https://github.com/c-cube/moonpool.git synced 2025-12-06 11:15:38 -05:00
Code Issues Projects Releases Packages Wiki Activity Actions

alias for get_current_runner

Browse source
This commit is contained in:
Simon Cruanes 2024-09-05 09:33:54 -04:00
parent 9b3c75124e
commit 65bc3c97ff
No known key found for this signature in database
GPG key ID: EBFFF6F283F3A2B4
2 changed files with 5 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
src/core/moonpool.ml
View file

@ -8,6 +8,7 @@ let start_thread_on_some_domain f x =
let run_async = Runner.run_async let run_async = Runner.run_async
let run_wait_block = Runner.run_wait_block let run_wait_block = Runner.run_wait_block
let get_current_runner = Runner.get_current_runner
let recommended_thread_count () = Domain_.recommended_number () let recommended_thread_count () = Domain_.recommended_number ()
let spawn = Fut.spawn let spawn = Fut.spawn
let spawn_on_current_runner = Fut.spawn_on_current_runner let spawn_on_current_runner = Fut.spawn_on_current_runner

4
src/core/moonpool.mli
View file

@ -69,6 +69,10 @@ val spawn_on_current_runner : (unit -> 'a) -> 'a Fut.t
(** See {!Fut.spawn_on_current_runner}. (** See {!Fut.spawn_on_current_runner}.
@since 0.5 *) @since 0.5 *)
val get_current_runner : unit -> Runner.t option
(** See {!Runner.get_current_runner}
@since NEXT_RELEASE *)
[@@@ifge 5.0] [@@@ifge 5.0]
val await : 'a Fut.t -> 'a val await : 'a Fut.t -> 'a