join() OrderedEnqueuer.executor to prevent zombies (#7059)

Esse commit está contido em:
Gökçen Eraslan
2017-06-21 19:50:10 +02:00
commit de François Chollet
commit 75470e380f
+1
Ver Arquivo
@@ -515,6 +515,7 @@ class OrderedEnqueuer(SequenceEnqueuer):
self.queue.unfinished_tasks = 0
self.queue.not_full.notify()
self.executor.close()
self.executor.join()
self.run_thread.join(timeout)