traverseda
/
cpython
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Merged revisions 78653 via svnmerge from 

svn+ssh://pythondev@svn.python.org/python/trunk

........
  r78653 | florent.xicluna | 2010-03-04 16:58:54 +0100 (jeu, 04 mar 2010) | 2 lines

  #7805: wait until all workers are started before collecting their PIDs
........
This commit is contained in:
Florent Xicluna 2010-03-04 16:10:10 +00:00
parent 931bb02d96
commit fb190f64b2
1 changed files with 9 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
Lib/test/test_multiprocessing.py
View File

@ -1071,8 +1071,16 @@ class _TestPoolWorkerLifetime(BaseTestCase):
self.assertEqual(res.get(), sqr(j)) self.assertEqual(res.get(), sqr(j))
# Refill the pool # Refill the pool
p._repopulate_pool() p._repopulate_pool()
# Finally, check that the worker pids have changed # Wait until all workers are alive
countdown = 5
while countdown and not all(w.is_alive() for w in p._pool):
countdown -= 1
time.sleep(DELTA)
finalworkerpids = [w.pid for w in p._pool] finalworkerpids = [w.pid for w in p._pool]
# All pids should be assigned. See issue #7805.
self.assertNotIn(None, origworkerpids)
self.assertNotIn(None, finalworkerpids)
# Finally, check that the worker pids have changed
self.assertNotEqual(sorted(origworkerpids), sorted(finalworkerpids)) self.assertNotEqual(sorted(origworkerpids), sorted(finalworkerpids))
p.close() p.close()
p.join() p.join()