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

details in test

Browse source
This commit is contained in:
Simon Cruanes 2023-07-17 10:54:47 -04:00
parent 8e9628ac81
commit d18e88a772
No known key found for this signature in database
GPG key ID: EBFFF6F283F3A2B4
1 changed files with 5 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
test/effect-based/t_fib_fork_join_all.ml
View file

@ -1,5 +1,7 @@
[@@@ifge 5.0] [@@@ifge 5.0]
let ( let@ ) = ( @@ )
open Moonpool open Moonpool
let rec fib_direct x = let rec fib_direct x =
@ -9,6 +11,7 @@ let rec fib_direct x =
fib_direct (x - 1) + fib_direct (x - 2) fib_direct (x - 1) + fib_direct (x - 2)
let rec fib x : int = let rec fib x : int =
(* some cutoff for sequential computation *)
if x <= 18 then if x <= 18 then
fib_direct x fib_direct x
else ( else (
@ -19,13 +22,13 @@ let rec fib x : int =
) )
let fib_40 : int = let fib_40 : int =
let pool = Pool.create ~min:8 () in let@ pool = Pool.with_ ~min:8 () in
Fut.spawn ~on:pool (fun () -> fib 40) |> Fut.wait_block_exn Fut.spawn ~on:pool (fun () -> fib 40) |> Fut.wait_block_exn
let () = Printf.printf "fib 40 = %d\n%!" fib_40 let () = Printf.printf "fib 40 = %d\n%!" fib_40
let run_test () = let run_test () =
let pool = Pool.create ~min:8 () in let@ pool = Pool.with_ ~min:8 () in
let fut = let fut =
Fut.spawn ~on:pool (fun () -> Fut.spawn ~on:pool (fun () ->