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 35076d9 commit dff841aCopy full SHA for dff841a
Lib/test/test_concurrent_futures/test_interpreter_pool.py
@@ -368,12 +368,18 @@ def run(ready, blocker):
368
for i in range(numtasks):
369
fut = executor.submit(run, ready, blocker)
370
futures.append(fut)
371
- # Wait for them all to be ready.
372
- for i in range(numtasks):
373
- ready.get() # blocking
+ assert len(executor._threads) == numtasks, len(executor._threads)
374
# Unblock the workers.
375
376
blocker.put_nowait(None)
+# try:
+# # Wait for them all to be ready.
377
+# for i in range(numtasks):
378
+# ready.get() # blocking
379
+# finally:
380
+# # Unblock the workers.
381
382
+# blocker.put_nowait(None)
383
finally:
384
executor.shutdown(wait=True)
385
0 commit comments