mirror of
https://github.com/python/cpython.git
synced 2025-11-14 07:49:28 +00:00
finalize the queue prior to shutdown
This commit is contained in:
parent
5e95e763e1
commit
019ce773cd
1 changed files with 2 additions and 0 deletions
|
|
@ -1208,10 +1208,12 @@ class _TestManagerRestart(BaseTestCase):
|
||||||
p.start()
|
p.start()
|
||||||
queue = manager.get_queue()
|
queue = manager.get_queue()
|
||||||
self.assertEqual(queue.get(), 'hello world')
|
self.assertEqual(queue.get(), 'hello world')
|
||||||
|
del queue
|
||||||
manager.shutdown()
|
manager.shutdown()
|
||||||
manager = QueueManager(
|
manager = QueueManager(
|
||||||
address=('localhost', 9999), authkey=authkey, serializer=SERIALIZER)
|
address=('localhost', 9999), authkey=authkey, serializer=SERIALIZER)
|
||||||
manager.start()
|
manager.start()
|
||||||
|
manager.shutdown()
|
||||||
|
|
||||||
#
|
#
|
||||||
#
|
#
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue