We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 3494396 commit 68f95f9Copy full SHA for 68f95f9
Lib/test/_test_multiprocessing.py
@@ -1235,7 +1235,18 @@ def test_get(self):
1235
break
1236
self.assertEqual(queue_empty(queue), False)
1237
1238
- self.assertEqual(queue.get_nowait(), 1)
+ for _ in support.sleeping_retry(support.SHORT_TIMEOUT):
1239
+ try:
1240
+ value = queue.get_nowait()
1241
+ except pyqueue.Empty:
1242
+ # Queue.empty() may become false before the feeder thread
1243
+ # flushes objects to the pipe.
1244
+ continue
1245
+ else:
1246
+ break
1247
1248
+ self.fail("queue.get_nowait() unexpectedly raised Empty")
1249
+ self.assertEqual(value, 1)
1250
self.assertEqual(queue.get(True, None), 2)
1251
self.assertEqual(queue.get(True), 3)
1252
self.assertEqual(queue.get(timeout=1), 4)
0 commit comments