From 16663651d6c515ab3cb3feaaf80d4b6da1647e8f Mon Sep 17 00:00:00 2001 From: Simon Cruanes Date: Fri, 24 Nov 2023 23:12:20 -0500 Subject: [PATCH] update test --- test/t_ws_wait.ml | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) diff --git a/test/t_ws_wait.ml b/test/t_ws_wait.ml index 263a3e90..29d276ca 100644 --- a/test/t_ws_wait.ml +++ b/test/t_ws_wait.ml @@ -4,12 +4,12 @@ let ( let@ ) = ( @@ ) let () = let sum = Atomic.make 0 in - let n = 300_000 in + let n = 100_000 in (let@ pool = Ws_pool.with_ ~num_threads:30 () in for _i = 1 to n do Runner.run_async pool (fun () -> - Thread.yield (); + Thread.delay 0.0001; ignore (Atomic.fetch_and_add sum 20 : int)) done; Runner.shutdown pool); @@ -17,5 +17,8 @@ let () = (* make sure that shutdown didn't terminate before all tasks were run *) let sum = Atomic.get sum in - assert (sum = 20 * n); + let expected = 20 * n in + + Printf.printf "sum=%d, expected=%d\n%!" sum expected; + assert (sum = expected); ()