executor.py 文件源码

def wait(self):
        if self.value is PENDING:
            if self.thread not in (None, eventlet.getcurrent()):
                self.thread.wait()
        for ch in self.children:
            ch.wait()
        if self.child_errors > 0 and self.value is not ERROR:
            errors = [e for e in self.leaf_errors if not e._recovered]
            if errors:
                self.value = ERROR
                self.exception = (ChildError, ChildError(self, self.leaf_errors), None)