There's a race condition in concurrent.futures in _AllCompletedWaiter, which affects wait(return_when=ALL_COMPLETED).

The attached test will go into an infinite wait.

Patch attached.

Could your patch also include a proper test case in Lib/test/test_concurrent_futures.py ?

I'll add this shortly.

Patch with a test included. Being a nondeterministic bug, please adjust the thread count, or timing as necessary, the parameters in the patch are as low as I can get them and still reasonably reproduce the bug (linux 3.2, i386).

There's a few complications in testing this. Firstly timeouts cannot be used, because at the end of the timeout, all the futures are checked to categorize them into done and not done. Except for taking the entire duration of the timeout given to return, the bug is masked in this case.

Secondly, it can't be known how long a wait *should* take, so failing after some duration and assuming a stall due to the race decrementing num_pending_calls would be a guess dependent on the capabilities of the system.

If a timeout needs to be added (and fired from an outside thread for reasons given above), please let me know, and direct me to an example of this kind of testing elsewhere in the stdlib, so I can do this idiomatically.

Without applying the patch, the test case provided will (usually) hang indefinitely.

New changeset 0312db5265d0 by Antoine Pitrou in branch '3.2':
Issue #14406: Fix a race condition when using `concurrent.futures.wait(return_when=ALL_COMPLETED)`.
http://hg.python.org/cpython/rev/0312db5265d0

New changeset 2c1432552213 by Antoine Pitrou in branch 'default':
Issue #14406: Fix a race condition when using `concurrent.futures.wait(return_when=ALL_COMPLETED)`.
http://hg.python.org/cpython/rev/2c1432552213

The patch looks fine, I've committed it. Thanks!

I think having a lock here is unnecessary. The following code should work:

def _decrement_pending_calls(self):
    if self.num_pending_calls == len(self.finished_futures):
         self.event.set()

(well, maybe the method should also be renamed then)