def kill_worker(self, pid, sig=signal.SIGQUIT):
"""
???????????
@param pid: ??kill?????
@type pid: Int
@param sig: kill?????
@type sig: Signal
"""
try:
os.kill(pid, sig)
except OSError as e:
if e.errno == errno.ESRCH:
try:
worker = self.WORKERS.pop(pid)
#TODO: clean worker
except (KeyError, OSError):
return
else:
raise e
评论列表
文章目录