Issue #12285: multiprocessing.Pool() raises a ValueError if the number of
processes if negative or null.
This commit is contained in:
parent
3fdf9d43e5
commit
f64a0cffca
|
@ -125,6 +125,8 @@ class Pool(object):
|
|||
processes = cpu_count()
|
||||
except NotImplementedError:
|
||||
processes = 1
|
||||
if processes < 1:
|
||||
raise ValueError("Number of processes must be at least 1")
|
||||
|
||||
if initializer is not None and not hasattr(initializer, '__call__'):
|
||||
raise TypeError('initializer must be a callable')
|
||||
|
|
|
@ -1085,6 +1085,9 @@ class _TestPool(BaseTestCase):
|
|||
self.assertEqual(sorted(it), map(sqr, range(1000)))
|
||||
|
||||
def test_make_pool(self):
|
||||
self.assertRaises(ValueError, multiprocessing.Pool, -1)
|
||||
self.assertRaises(ValueError, multiprocessing.Pool, 0)
|
||||
|
||||
p = multiprocessing.Pool(3)
|
||||
self.assertEqual(3, len(p._pool))
|
||||
p.close()
|
||||
|
|
Loading…
Reference in New Issue