Ticket #5: turbomail-2.0.3-timeout.patch

turbomail/pool.py

@@ -59 +59 @@
                 
                 log.debug("Thread pool created.")
         
-        def enqueue(self, work):
+        def enqueue(self, work, block=True, timeout=None):
                 """Enqueue a Message instance.
                 
                 @param work: The unit of work can be any callable that returns a
@@ -71 +71 @@
                 """
 
                 if callable(work):
-                        self._queue.put(work())
+                        self._queue.put(work(), block, timeout)
                 else:
-                        self._queue.put(work)
+                        self._queue.put(work, block, timeout)
                 
                 optimum_threads = min(self._threads, math.ceil(self._queue.qsize() / float(self._jobs)))