python
diff --git a/‎Lib/test/_test_multiprocessing.py
Copy file name to clipboardExpand all lines: Lib/test/_test_multiprocessing.py
+3Lines changed: 3 additions & 0 deletions b/‎Lib/test/_test_multiprocessing.py
Copy file name to clipboardExpand all lines: Lib/test/_test_multiprocessing.py
+3Lines changed: 3 additions & 0 deletions
@@ -1281,6 +1281,7 @@ def test_closed_queue_put_get_exceptions(self):
     def test_shutdown_empty(self):
         for q in multiprocessing.Queue(), multiprocessing.JoinableQueue():
             q.shutdown()
+            _wait()
             with self.assertRaises(
                 pyqueue.ShutDown, msg="Didn't appear to shut-down queue"
                 ):
@@ -1294,6 +1295,7 @@ def test_shutdown_nonempty(self):
         for q in multiprocessing.Queue(1), multiprocessing.JoinableQueue(1):
             q.put("data")
             q.shutdown()
+            _wait()
             q.get()
             with self.assertRaises(
                 pyqueue.ShutDown, msg="Didn't appear to shut-down queue"
@@ -1304,6 +1306,7 @@ def test_shutdown_immediate(self):
         for q in multiprocessing.Queue(), multiprocessing.JoinableQueue():
             q.put("data")
             q.shutdown(immediate=True)
+            _wait()
             with self.assertRaises(
                 pyqueue.ShutDown, msg="Didn't appear to shut-down queue"
                 ):