tests: compat 4.x

This commit is contained in:
Simon Cruanes 2023-07-09 22:07:44 -04:00
parent 427c462778
commit e73c1a2966
No known key found for this signature in database
GPG key ID: EBFFF6F283F3A2B4
8 changed files with 30 additions and 0 deletions

View file

@ -2,6 +2,8 @@
(tests (tests
(names t_fib1 t_futs1 t_many t_fib_fork_join (names t_fib1 t_futs1 t_many t_fib_fork_join
t_fib_fork_join_all t_sort t_fork_join) t_fib_fork_join_all t_sort t_fork_join)
(preprocess (action
(run %{project_root}/src/cpp/cpp.exe %{input-file})))
(enabled_if (>= %{ocaml_version} 5.0)) (enabled_if (>= %{ocaml_version} 5.0))
(libraries moonpool trace ;tracy-client.trace (libraries moonpool trace ;tracy-client.trace
)) ))

View file

@ -1,3 +1,5 @@
[@@@ifge 5.0]
open Moonpool open Moonpool
let rec fib_direct x = let rec fib_direct x =
@ -48,3 +50,5 @@ let () =
(* 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
[@@@endif]

View file

@ -1,3 +1,5 @@
[@@@ifge 5.0]
open Moonpool open Moonpool
let rec fib_direct x = let rec fib_direct x =
@ -49,3 +51,5 @@ let () =
(* 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
[@@@endif]

View file

@ -1,3 +1,5 @@
[@@@ifge 5.0]
open Moonpool open Moonpool
let rec fib_direct x = let rec fib_direct x =
@ -40,3 +42,5 @@ let () =
(* 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
[@@@endif]

View file

@ -1,3 +1,5 @@
[@@@ifge 5.0]
open Moonpool open Moonpool
let pool = Pool.create ~min:4 () let pool = Pool.create ~min:4 ()
@ -36,3 +38,5 @@ let () =
in in
let exp_sum = List.init 42 (fun x -> x * x) |> List.fold_left ( + ) 0 in let exp_sum = List.init 42 (fun x -> x * x) |> List.fold_left ( + ) 0 in
assert (par_sum = exp_sum) assert (par_sum = exp_sum)
[@@@endif]

View file

@ -1,3 +1,5 @@
[@@@ifge 5.0]
open! Moonpool open! Moonpool
let pool = Pool.create ~min:4 () let pool = Pool.create ~min:4 ()
@ -51,3 +53,5 @@ let () =
in in
let fut = Fut.both f1 f2 in let fut = Fut.both f1 f2 in
assert (Fut.wait_block fut = Ok (2, 20)) assert (Fut.wait_block fut = Ok (2, 20))
[@@@endif]

View file

@ -1,3 +1,5 @@
[@@@ifge 5.0]
open Moonpool open Moonpool
let pool = Pool.create ~min:4 () let pool = Pool.create ~min:4 ()
@ -27,3 +29,5 @@ let run () =
assert (List.for_all (fun s -> s = n) lens) assert (List.for_all (fun s -> s = n) lens)
let () = run () let () = run ()
[@@@endif]

View file

@ -1,3 +1,5 @@
[@@@ifge 5.0]
open Moonpool open Moonpool
let rec select_sort arr i len = let rec select_sort arr i len =
@ -66,3 +68,5 @@ let () =
(* Printf.printf "arr: [%s]\n%!" *) (* Printf.printf "arr: [%s]\n%!" *)
(* (String.concat ", " @@ List.map string_of_int @@ Array.to_list arr); *) (* (String.concat ", " @@ List.map string_of_int @@ Array.to_list arr); *)
assert (sorted arr) assert (sorted arr)
[@@@endif]