aboutsummaryrefslogtreecommitdiff
path: root/stm/asyncTaskQueue.ml
diff options
context:
space:
mode:
authorEnrico Tassi2019-01-21 13:46:31 +0100
committerEnrico Tassi2019-01-22 18:03:18 +0100
commit816d8e6723c7272f2df0ff9e614f8a0fe19f66c9 (patch)
tree08547fb1a9ef780d2e7b56e99de17db3866f7b89 /stm/asyncTaskQueue.ml
parent05e2222e04323d11429d659b415750cf40e2babd (diff)
[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.
Diffstat (limited to 'stm/asyncTaskQueue.ml')
-rw-r--r--stm/asyncTaskQueue.ml4
1 files changed, 2 insertions, 2 deletions
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 } =