simon/moonpool
1
0
Fork 0
mirror of https://github.com/c-cube/moonpool.git synced 2025-12-09 04:35:33 -05:00
Code Issues Projects Releases Packages Wiki Activity Actions

compat 4.x

Browse source
This commit is contained in:
Simon Cruanes 2023-07-09 22:04:18 -04:00
parent 68e744290b
commit 427c462778
No known key found for this signature in database
GPG key ID: EBFFF6F283F3A2B4
3 changed files with 16 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
src/pool.ml
View file

@ -69,6 +69,8 @@ let num_tasks_ (self : state) : int =
Array.iter (fun q -> n := !n + Bb_queue.size q) self.qs; Array.iter (fun q -> n := !n + Bb_queue.size q) self.qs;
!n !n
[@@@ifge 5.0]
(* DLA interop *) (* DLA interop *)
let prepare_for_await () : Dla_.t = let prepare_for_await () : Dla_.t =
(* current state *) (* current state *)
@ -89,6 +91,12 @@ let prepare_for_await () : Dla_.t =
let t = { Dla_.release; await } in let t = { Dla_.release; await } in
t t
[@@@else_]
let prepare_for_await () = { Dla_.release = ignore; await = ignore }
[@@@endif]
exception Got_task of task exception Got_task of task
type around_task = AT_pair : (t -> 'a) * (t -> 'a -> unit) -> around_task type around_task = AT_pair : (t -> 'a) * (t -> 'a -> unit) -> around_task

4
src/suspend_.ml
View file

@ -33,4 +33,8 @@ let with_suspend ~(run : with_handler:bool -> task -> unit) (f : unit -> unit) :
E.try_with f () { E.effc } E.try_with f () { E.effc }
[@@@ocaml.alert "+unstable"] [@@@ocaml.alert "+unstable"]
[@@@else_]
let with_suspend ~run:_ f = f ()
[@@@endif] [@@@endif]

6
src/suspend_.mli
View file

@ -48,11 +48,13 @@ val suspend : suspension_handler -> unit
and a task runner function. and a task runner function.
*) *)
[@@@endif]
val with_suspend : val with_suspend :
run:(with_handler:bool -> task -> unit) -> (unit -> unit) -> unit run:(with_handler:bool -> task -> unit) -> (unit -> unit) -> unit
(** [with_suspend ~run f] runs [f()] in an environment where [suspend] (** [with_suspend ~run f] runs [f()] in an environment where [suspend]
will work. If [f()] suspends with suspension handler [h], will work. If [f()] suspends with suspension handler [h],
this calls [h ~run k] where [k] is the suspension. this calls [h ~run k] where [k] is the suspension.
*)
[@@@endif] This will not do anything on OCaml 4.x.
*)