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()
评论列表
文章目录