aboutsummaryrefslogtreecommitdiff
path: root/stm/asyncTaskQueue.ml
diff options
context:
space:
mode:
authorEmilio Jesus Gallego Arias2019-01-24 14:25:09 +0100
committerEmilio Jesus Gallego Arias2019-01-24 14:25:09 +0100
commitea6c157e7a47039d2c1505e896dbdd099a0da450 (patch)
tree6bf2035eee82d12be341602edb3653991399cb07 /stm/asyncTaskQueue.ml
parentf5241b99bb15f019eb629a7f24f2993f011e7e06 (diff)
parentaa4f1346e7cf2f8424259143d7aca6a883d3f9d2 (diff)
Merge PR #9372: [thread] protect threads against sigalrm
Reviewed-by: ejgallego
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 } =