diff options
| author | Enrico Tassi | 2015-02-10 08:34:00 +0100 |
|---|---|---|
| committer | Enrico Tassi | 2015-02-16 17:53:06 +0100 |
| commit | ffe7fc6ff44ec94544123c47b3d01bdec05b3fe0 (patch) | |
| tree | d7ec22629888e0632ae0f8139b378d3e86cb8344 /stm/asyncTaskQueue.ml | |
| parent | cce1b6f06f9802f4d7c977322cec654ad2582d63 (diff) | |
*Queue: API to wake up all threads
Diffstat (limited to 'stm/asyncTaskQueue.ml')
| -rw-r--r-- | stm/asyncTaskQueue.ml | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/stm/asyncTaskQueue.ml b/stm/asyncTaskQueue.ml index 672527d9b5..e3fb0b607a 100644 --- a/stm/asyncTaskQueue.ml +++ b/stm/asyncTaskQueue.ml @@ -177,7 +177,7 @@ module Make(T : Task) = struct if not (Worker.is_alive proc) then () else if cancelled () || !(!expiration_date) then let () = stop_waiting := true in - let () = TQueue.signal_destruction queue in + let () = TQueue.broadcast queue in Worker.kill proc else let () = Unix.sleep 1 in @@ -253,6 +253,8 @@ module Make(T : Task) = struct Pool.destroy active; TQueue.destroy queue + let broadcast { queue } = TQueue.broadcast queue + let enqueue_task { queue; active } (t, _ as item) = prerr_endline ("Enqueue task "^T.name_of_task t); TQueue.push queue item |