def run(self):
proc_name = self.name
while True:
next_task = self.task_queue.get()
if next_task is None:
print("%s: Exiting" % proc_name)
self.task_queue.task_done()
break
print('%s: %s' % (proc_name, next_task))
result = next_task()
self.task_queue.task_done()
self.result_queue.put(result)
if next_task.exclusive:
print("%s: Exiting (exclusive)" % proc_name)
break
return
评论列表
文章目录