fixup! Benchmark: add ezbechamel_concurrent

edwintorok · Oct 10, 2023 · efcf1f4 · efcf1f4
1 parent 1350311
commit efcf1f4
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/ocaml/tests/bench/lib/concurrent/ezbechamel_concurrent.ml b/ocaml/tests/bench/lib/concurrent/ezbechamel_concurrent.ml
@@ -43,11 +43,12 @@ module Worker = struct
         signal t.stopped ; worker_loop ()
       )
     in
+    signal t.initialized;
     Fun.protect ~finally worker_loop
 
   let make ~allocate ~free ~run _ =
-    let start = semaphore () and stopped = semaphore () in
-    let t = {start; stopped; quit= Atomic.make false; result = Atomic.make None} in
+    let start = semaphore () and stopped = semaphore () and initialized = semaphore () in
+    let t = {start; stopped;initialized; quit= Atomic.make false; result = Atomic.make None} in
     (t, Thread.create (worker ~allocate ~free ~run) t)
 
   let signal_start (t, _) = signal t.start