Issue #20319: concurrent.futures.wait() can block forever even if Futures have completed

Lib/concurrent/futures/_base.py

@@ -225,6 +225,7 @@ def as_completed(fs, timeout=None):
 
     finally:
         for f in fs:
+            with f._condition:
                 f._waiters.remove(waiter)
 
 DoneAndNotDoneFutures = collections.namedtuple(
@@ -272,6 +273,7 @@ def wait(fs, timeout=None, return_when=ALL_COMPLETED):
 
     waiter.event.wait(timeout)
     for f in fs:
+        with f._condition:
             f._waiters.remove(waiter)
 
     done.update(waiter.finished_futures)

Misc/NEWS

@@ -69,6 +69,12 @@ Library
 
 - Issue #17481: inspect.getfullargspec() now uses inspect.signature() API.
 
+- Issue #15304: concurrent.futures.wait() can block forever even if
+  Futures have completed. Patch by Glenn Langford.
+
+Fix warning message when `os.chdir()` fails inside
+  `test.support.temp_cwd()`.  Patch by Chris Jerdonek.
+
 IDLE
 ----