Commit a6becaa9 authored by Richard Oudkerk's avatar Richard Oudkerk

Fix dangling warning for test_multiprocessing

parent bf4e2663
...@@ -548,7 +548,10 @@ class BaseManager(object): ...@@ -548,7 +548,10 @@ class BaseManager(object):
''' '''
Join the manager process (if it has been spawned) Join the manager process (if it has been spawned)
''' '''
self._process.join(timeout) if self._process is not None:
self._process.join(timeout)
if not self._process.is_alive():
self._process = None
def _debug_info(self): def _debug_info(self):
''' '''
......
...@@ -2516,6 +2516,7 @@ class TestInitializers(unittest.TestCase): ...@@ -2516,6 +2516,7 @@ class TestInitializers(unittest.TestCase):
def tearDown(self): def tearDown(self):
self.mgr.shutdown() self.mgr.shutdown()
self.mgr.join()
def test_manager_initializer(self): def test_manager_initializer(self):
m = multiprocessing.managers.SyncManager() m = multiprocessing.managers.SyncManager()
...@@ -2523,6 +2524,7 @@ class TestInitializers(unittest.TestCase): ...@@ -2523,6 +2524,7 @@ class TestInitializers(unittest.TestCase):
m.start(initializer, (self.ns,)) m.start(initializer, (self.ns,))
self.assertEqual(self.ns.test, 1) self.assertEqual(self.ns.test, 1)
m.shutdown() m.shutdown()
m.join()
def test_pool_initializer(self): def test_pool_initializer(self):
self.assertRaises(TypeError, multiprocessing.Pool, initializer=1) self.assertRaises(TypeError, multiprocessing.Pool, initializer=1)
...@@ -2818,6 +2820,7 @@ def test_main(run=None): ...@@ -2818,6 +2820,7 @@ def test_main(run=None):
ManagerMixin.pool.terminate() ManagerMixin.pool.terminate()
ManagerMixin.pool.join() ManagerMixin.pool.join()
ManagerMixin.manager.shutdown() ManagerMixin.manager.shutdown()
ManagerMixin.manager.join()
ThreadsMixin.pool.join() ThreadsMixin.pool.join()
ProcessesMixin.pool.join() ProcessesMixin.pool.join()
del ProcessesMixin.pool, ThreadsMixin.pool, ManagerMixin.pool del ProcessesMixin.pool, ThreadsMixin.pool, ManagerMixin.pool
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment