在研究了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方法,但没有任何改进.我也在os.kill之前和之后玩过关闭/加入池.这个循环,它永远不会结束,一旦它到达os.kill我得到一个僵尸进程. self.pool =池(processes = 4)发生在守护进程的__init__部分.从start(self)之后的run(self),我将调用self.pool.apply_async(self.runCmd,[cmd,10],callback = self.logoutput).但是,我想在讨论之前解决这个僵尸进程.
如何在守护进程中正确实现池以避免这个僵尸进程？
>编写一个信号处理程序,用于子/守护程序进程,捕获SIGTERM信号并触发主线程的事件
>在子/守护程序进程的主线程(非常重要)中安装信号处理程序
> SIGTERM的事件处理程序必须向子/守护程序进程中的所有线程发出停止指令
>所有线程在完成后必须加入()ed(如果你假设SIGTERM会自动销毁你可能必须实现这个逻辑的所有东西)
>一旦所有内容都加入并清理完毕,您就可以退出主线程
如果你有I / O线程和各种各样的东西那么这将是一个真正的苦差事.
此外,我通过实验发现,当您使用信号处理程序时,事件监听器的特定策略很重要.例如,如果使用select.select(),则必须使用超时,并在超时发生时重试;否则你的信号处理程序将无法运行.如果您有事件的Queue.Queue对象,并且您的事件侦听器调用其.get()方法,否则您的信号处理程序将无法运行. (在VM中的C中实现的“真实”信号处理程序运行,但除非您使用超时,否则您的Python信号处理程序不会运行.)
祝好运！