From 816d8e6723c7272f2df0ff9e614f8a0fe19f66c9 Mon Sep 17 00:00:00 2001 From: Enrico Tassi Date: Mon, 21 Jan 2019 13:46:31 +0100 Subject: [thread] protect threads against sigalrm This makes the implementation of Timeout on unix more reliable since only the main thread will receive the signal for timeout. --- stm/asyncTaskQueue.ml | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) (limited to 'stm/asyncTaskQueue.ml') diff --git a/stm/asyncTaskQueue.ml b/stm/asyncTaskQueue.ml index 51166cf238..2f8129bbfd 100644 --- a/stm/asyncTaskQueue.ml +++ b/stm/asyncTaskQueue.ml @@ -190,7 +190,7 @@ module Make(T : Task) () = struct let () = TQueue.broadcast queue in Worker.kill proc in - let _ = Thread.create kill_if () in + let _ = CThread.create kill_if () in try while true do report_status ~id "Idle"; @@ -250,7 +250,7 @@ module Make(T : Task) () = struct { active = Pool.create queue ~size; queue; - cleaner = if size > 0 then Some (Thread.create cleaner queue) else None; + cleaner = if size > 0 then Some (CThread.create cleaner queue) else None; } let destroy { active; queue } = -- cgit v1.2.3