Empty the multiprocessing queue before terminating it

daid · Aug 2, 2016 · a4c3469 · a4c3469
1 parent 31a59c9
commit a4c3469
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/tools/toolchains/__init__.py b/tools/toolchains/__init__.py
@@ -794,6 +794,9 @@ def compile_queue(self, queue, objects):
                             ])
                         objects.append(result['object'])
                     except ToolException, err:
+                        if p._taskqueue.queue:
+                            p._taskqueue.queue.clear()
+                            sleep(0.5)
                         p.terminate()
                         p.join()
                         raise ToolException(err)