diff options
Diffstat (limited to 'concurrent/futures/_base.py')
| -rw-r--r-- | concurrent/futures/_base.py | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/concurrent/futures/_base.py b/concurrent/futures/_base.py index 1d90211..aaefa2b 100644 --- a/concurrent/futures/_base.py +++ b/concurrent/futures/_base.py @@ -122,8 +122,7 @@ class _AllCompletedWaiter(_Waiter): super(_AllCompletedWaiter, self).__init__() def _decrement_pending_calls(self): - self.num_pending_calls -= 1 - if not self.num_pending_calls: + if self.num_pending_calls == len(self.finished_futures): self.event.set() def add_result(self, future): |