Changeset 16 for trunk/lib/nanownlib/parallel.py

Timestamp:

08/01/15 19:01:31 (9 years ago)

Author:

tim

Message:

.

File:

• trunk/lib/nanownlib/parallel.py (modified) (1 diff)

trunk/lib/nanownlib/parallel.py

@@ -48 +48 @@
     
     def stop(self):
-        for i in range(0,len(self.workers)):
+        try:
+            while True:
+                self.workq.get(block=False)
+                self.workq.task_done()
+        except queue.Empty as e:
+            pass
+        
+        for i in range(len(self.workers)):
             self.workq.put(None)
         for w in self.workers: