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

details in test

Browse source
This commit is contained in:
Simon Cruanes 2024-02-02 23:29:17 -05:00
parent e8cc87f1f5
commit e1219ade54
No known key found for this signature in database
GPG key ID: EBFFF6F283F3A2B4
1 changed files with 8 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
test/effect-based/t_fib1.ml
View file

@ -2,6 +2,8 @@
open Moonpool open Moonpool
let ( let@ ) = ( @@ )
let rec fib_direct x = let rec fib_direct x =
if x <= 1 then if x <= 1 then
1 1
@ -18,7 +20,7 @@ let fib ~on x : int Fut.t =
Fut.await t1 + Fut.await t2 Fut.await t1 + Fut.await t2
) )
in in
Fut.spawn ~on (fun () -> fib_rec x) Fut.spawn ~name:"fib" ~on (fun () -> fib_rec x)
(* NOTE: for tracy support (* NOTE: for tracy support
let () = Tracy_client_trace.setup () let () = Tracy_client_trace.setup ()
@ -46,9 +48,13 @@ let run_test () =
assert (res = Ok (Array.make 3 fib_40)) assert (res = Ok (Array.make 3 fib_40))
let () = let main () =
(* now make sure we can do this with multiple pools in parallel *) (* now make sure we can do this with multiple pools in parallel *)
let jobs = Array.init 2 (fun _ -> Thread.create run_test ()) in let jobs = Array.init 2 (fun _ -> Thread.create run_test ()) in
Array.iter Thread.join jobs Array.iter Thread.join jobs
let () =
let@ () = Trace_tef.with_setup () in
main ()
[@@@endif] [@@@endif]