diff options
| author | Florent Xicluna <florent.xicluna@gmail.com> | 2010-03-08 13:32:17 (GMT) |
|---|---|---|
| committer | Florent Xicluna <florent.xicluna@gmail.com> | 2010-03-08 13:32:17 (GMT) |
| commit | 998171f0d72b270bd578ee9d6fc4937f0cc9776b (patch) | |
| tree | dbf03a7763d151b302aa94dd5bf3b3722fe864f8 /Lib/multiprocessing/pool.py | |
| parent | 4886d246a89895a25c4733d537fdcfdede5e50f9 (diff) | |
| download | cpython-998171f0d72b270bd578ee9d6fc4937f0cc9776b.zip cpython-998171f0d72b270bd578ee9d6fc4937f0cc9776b.tar.gz cpython-998171f0d72b270bd578ee9d6fc4937f0cc9776b.tar.bz2 | |
Merged revisions 78777,78787,78790 via svnmerge from
svn+ssh://pythondev@svn.python.org/python/trunk
........
r78777 | florent.xicluna | 2010-03-08 00:49:03 +0100 (lun, 08 mar 2010) | 4 lines
Backport the Popen.poll() protection from subprocess to multiprocessing. See #1731717.
It should fix transient failures on test_multiprocessing.
........
r78787 | florent.xicluna | 2010-03-08 08:21:16 +0100 (lun, 08 mar 2010) | 2 lines
Don't fail on a debug() statement, if the worker PID is (still) None.
........
r78790 | florent.xicluna | 2010-03-08 12:01:39 +0100 (lun, 08 mar 2010) | 2 lines
On finalize, don't try to join not started process.
........
Diffstat (limited to 'Lib/multiprocessing/pool.py')
| -rw-r--r-- | Lib/multiprocessing/pool.py | 8 |
1 files changed, 3 insertions, 5 deletions
diff --git a/Lib/multiprocessing/pool.py b/Lib/multiprocessing/pool.py index 6271b86..d2b8dd1 100644 --- a/Lib/multiprocessing/pool.py +++ b/Lib/multiprocessing/pool.py @@ -448,12 +448,10 @@ class Pool(object): 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 %d' % w.pid) - w.join() + debug('cleaning up worker %d' % p.pid) + p.join() # # Class whose instances are returned by `Pool.apply_async()` |