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

update test

Browse source
This commit is contained in:
Simon Cruanes 2023-11-24 23:12:20 -05:00
parent b58041153a
commit 16663651d6
No known key found for this signature in database
GPG key ID: EBFFF6F283F3A2B4
1 changed files with 6 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
test/t_ws_wait.ml
View file

@ -4,12 +4,12 @@ let ( let@ ) = ( @@ )
let () = let () =
let sum = Atomic.make 0 in 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 (let@ pool = Ws_pool.with_ ~num_threads:30 () in
for _i = 1 to n do for _i = 1 to n do
Runner.run_async pool (fun () -> Runner.run_async pool (fun () ->
Thread.yield (); Thread.delay 0.0001;
ignore (Atomic.fetch_and_add sum 20 : int)) ignore (Atomic.fetch_and_add sum 20 : int))
done; done;
Runner.shutdown pool); Runner.shutdown pool);
@ -17,5 +17,8 @@ let () =
(* make sure that shutdown didn't terminate before (* make sure that shutdown didn't terminate before
all tasks were run *) all tasks were run *)
let sum = Atomic.get sum in 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);
() ()