Merge PR #1019: Fix BZ#5655 by avoiding the creation of a cleaner thread for empty queues.

1 files changed, 2 insertions, 2 deletions

diff --git a/stm/asyncTaskQueue.ml b/stm/asyncTaskQueue.ml
index 31ede2d8b..5d9b595d3 100644
--- a/stm/asyncTaskQueue.ml
+++ b/stm/asyncTaskQueue.ml
@@ -237,7 +237,7 @@ module Make(T : Task) = struct
   type queue = {
     active : Pool.pool;
     queue : (T.task * expiration) TQueue.t;
-    cleaner : Thread.t;
+    cleaner : Thread.t option;
   }
 
   let create size =
@@ -250,7 +250,7 @@ module Make(T : Task) = struct
     {
       active = Pool.create queue ~size;
       queue;
-      cleaner = Thread.create cleaner queue;
+      cleaner = if size > 0 then Some (Thread.create cleaner queue) else None;
     }
   
   let destroy { active; queue } =