__init__.py 文件源码

def _tasklet(self):
        while 1:
            item = self._task_queue.get(block=True)
            if item is None:
                self._task_queue.task_done()
                break
            task, target, args, kwargs = item
            try:
                val = target(*args, **kwargs)
                task._proceed_(val)
            except:
                task.throw(*sys.exc_info())
            finally:
                self._task_queue.task_done()