simon/ocaml-containers
1
0
Fork 0
mirror of https://github.com/c-cube/ocaml-containers.git synced 2025-12-06 11:15:31 -05:00
Code Issues Projects Releases Packages Wiki Activity Actions

test: use more deterministic test for timer

Browse source
This commit is contained in:
Simon Cruanes 2019-11-12 10:17:50 -06:00
parent 7cefde490b
commit 7bdf6f6cef
1 changed files with 5 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
src/threads/CCTimer.ml
View file

@ -157,16 +157,19 @@ let every ?delay timer d ~f =
let start = Unix.gettimeofday() in let start = Unix.gettimeofday() in
let timer = create() in let timer = create() in
let res = CCLock.create 0 in let res = CCLock.create 0 in
let sem = CCSemaphore.create 1 in
CCSemaphore.acquire 1 sem;
let stop = ref 0. in let stop = ref 0. in
every timer 0.1 every timer 0.1
~f:(fun () -> ~f:(fun () ->
if CCLock.incr_then_get res > 5 then ( if CCLock.incr_then_get res > 5 then (
stop := Unix.gettimeofday(); stop := Unix.gettimeofday();
CCSemaphore.release 1 sem;
raise ExitEvery raise ExitEvery
)); ));
Thread.delay 0.7; CCSemaphore.acquire 1 sem; (* wait *)
OUnit.assert_equal ~printer:CCInt.to_string 6 (CCLock.get res); OUnit.assert_equal ~printer:CCInt.to_string 6 (CCLock.get res);
OUnit.assert_bool "estimate delay" (abs_float (!stop -. start -. 0.5) < 0.1); OUnit.assert_bool "estimate delay" (abs_float (!stop -. start -. 0.5) < 0.2);
*) *)
let active timer = not timer.stop let active timer = not timer.stop