async.py 文件源码

def __call__(self, *args, **kwargs):

    def thunk():
      try:
        self.func(self.cb, self.eb, *args, **kwargs)
      except ExitNow:
        raise
      except Exception, e:
        self.eb(e)

    event_defer(thunk)
    if self.disable_signal_handlers:
      event_loop(catch_signals = ())
    else:
      event_loop()
    if not self.fin:
      logger.warning("%r event_loop terminated without callback or errback", self)
    if self.err is None:
      return self.res
    elif isinstance(self.err, tuple):
      raise self.err[0], self.err[1], self.err[2]
    else:
      raise self.err