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

another test

Browse source
This commit is contained in:
Simon Cruanes 2023-07-16 23:21:45 -04:00
parent f7d9e6c0c1
commit 366d26527c
No known key found for this signature in database
GPG key ID: EBFFF6F283F3A2B4
1 changed files with 21 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

22
test/effect-based/t_fork_join.ml
View file

@ -288,7 +288,7 @@ let t_for_nested ~min ~chunk_size () =
let ref_l2 = List.map (List.map neg) ref_l1 in let ref_l2 = List.map (List.map neg) ref_l1 in
let l1, l2 = let l1, l2 =
let@ pool = Pool.with_ ~min:4 () in let@ pool = Pool.with_ ~min () in
let@ () = Pool.run_wait_block pool in let@ () = Pool.run_wait_block pool in
let l1 = let l1 =
Fork_join.map_list ~chunk_size (Fork_join.map_list ~chunk_size neg) l Fork_join.map_list ~chunk_size (Fork_join.map_list ~chunk_size neg) l
@ -305,10 +305,30 @@ let t_for_nested ~min ~chunk_size () =
Q.Test.fail_reportf "l1=%s, ref_l1=%s" (ppl l2) (ppl ref_l2); Q.Test.fail_reportf "l1=%s, ref_l1=%s" (ppl l2) (ppl ref_l2);
true) true)
let t_map ~chunk_size () =
let ppa = Q.Print.(array string) in
Q.Test.make ~name:"map1"
Q.(small_list small_int |> Q.set_stats [ "len", List.length ])
(fun l ->
let@ pool = Pool.with_ ~min:4 () in
let@ () = Pool.run_wait_block pool in
let a1 =
Fork_join.map_list ~chunk_size string_of_int l |> Array.of_list
in
let a2 =
Fork_join.map_array ~chunk_size string_of_int @@ Array.of_list l
in
if a1 <> a2 then Q.Test.fail_reportf "a1=%s, a2=%s" (ppa a1) (ppa a2);
true)
let () = let () =
QCheck_base_runner.run_tests_main QCheck_base_runner.run_tests_main
[ [
t_eval; t_eval;
t_map ~chunk_size:1 ();
t_map ~chunk_size:50 ();
t_for_nested ~min:1 ~chunk_size:1 (); t_for_nested ~min:1 ~chunk_size:1 ();
t_for_nested ~min:4 ~chunk_size:1 (); t_for_nested ~min:4 ~chunk_size:1 ();
t_for_nested ~min:1 ~chunk_size:3 (); t_for_nested ~min:1 ~chunk_size:3 ();