commit d034b32f57013a1224b3b7c27789f7c285047011
author Florent Xicluna <florent.xicluna@gmail.com> Mon Mar 08 11:01:39 2010 +0000
committer Florent Xicluna <florent.xicluna@gmail.com> Mon Mar 08 11:01:39 2010 +0000
tree c5dd4b3b69f423bf7fcd08c84304401c7d3787e2
parent faf175385de454a99edef26986637fc80c8aaba7

On finalize, don't try to join not started process.

Lib/multiprocessing/pool.py

diff --git a/Lib/multiprocessing/pool.py b/Lib/multiprocessing/pool.py
index 2a8fae1..8555da9 100644
--- a/Lib/multiprocessing/pool.py
+++ b/Lib/multiprocessing/pool.py
@@ -447,12 +447,10 @@
         if pool and hasattr(pool[0], 'terminate'):
             debug('joining pool workers')
             for p in pool:
-                p.join()
-            for w in pool:
-                if w.exitcode is None:
+                if p.is_alive():
                     # worker has not yet exited
-                    debug('cleaning up worker %s' % w.pid)
-                    w.join()
+                    debug('cleaning up worker %d' % p.pid)
+                    p.join()
 
 #
 # Class whose instances are returned by `Pool.apply_async()`