在研究了 python 守护进程之后,这个演练似乎是最可靠的:http://www.jejik.com/articles/2007/02/a_simple_unix_linux_daemon_in_python/
现在我试图在守护进程类中实现一个工作池,我相信它正在工作(我没有彻底测试代码),除了在关闭时我得到一个僵尸进程。我已经读过我需要等待孩子的返回代码,但我只是不知道我需要如何做到这一点。
以下是一些代码片段:
def stop(self):
...
try:
while 1:
self.pool.close()
self.pool.join()
os.kill(pid, SIGTERM)
time.sleep(0.1)
...
这里我尝试过os.killpg
以及一些os.wait
方法但没有改善。我也玩过closing
/joining
之前和之后的泳池os.kill
。这个循环就目前而言,永远不会结束,一旦到达os.kill
我得到一个僵尸进程。self.pool = Pool(processes=4)
发生在__init__
守护进程的部分。来自run(self)
这是在之后执行的start(self)
, 我会打电话self.pool.apply_async(self.runCmd, [cmd, 10], callback=self.logOutput)
。然而,我想在研究这个问题之前先解决这个僵尸进程。
如何在守护进程内正确实现池以避免出现僵尸进程?
如果不知道子进程/守护进程进程中发生了什么,就不可能对答案有 100% 的信心,但请考虑是否可能是这样。由于子进程中有工作线程,因此实际上需要构建一些逻辑,以便在收到 SIGTERM 后加入所有这些线程。否则,您的进程可能无法退出(即使退出,您也可能无法正常退出)。为此,您需要:
- 编写一个信号处理程序,用于捕获 SIGTERM 信号并为主线程触发事件的子/守护进程
- 在子/守护进程的主线程中安装信号处理程序(非常重要)
- SIGTERM 的事件处理程序必须向子进程/守护进程中的所有线程发出停止指令
- 所有线程完成后都必须进行 join()ed(如果您假设 SIGTERM 会自动销毁您可能必须实现此逻辑的所有内容)
- 一旦所有内容都加入并清理完毕,您就可以退出主线程
如果您有用于 I/O 和各种事情的线程,那么这将是一件真正的苦差事。
另外,我通过实验发现,当您使用信号处理程序时,事件侦听器的特定策略很重要。例如,如果使用 select.select(),则必须使用超时,如果发生超时则重试;否则你的信号处理程序将不会运行。如果您有一个用于事件的 Queue.Queue 对象,并且您的事件侦听器调用其 .get() 方法,则必须使用超时,否则您的信号处理程序将不会运行。 (在虚拟机中用 C 实现的“真正的”信号处理程序会运行,但 Python 信号处理程序不会运行,除非您使用超时。)
祝你好运!
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)