我有连续运行的 python 代码(收集传感器数据)。它应该在启动时使用 start-stop-daemon 启动。但是,我希望能够优雅地终止进程,所以我从 How to process SIGTERM signal gracefully? 帖子中的建议开始,并将我的主循环放在一个单独的线程中。我希望能够在它作为守护进程运行时(start-stop-daemon 将发送一个终止信号)以及当我自己在终端中短暂启动它以进行测试(我按下 ctrl-c )时能够优雅地关闭它。

但是,如果我终止进程,似乎不会调用信号处理程序(即使不使用线程,“done (killed) ”也永远不会出现在我重定向到的文件中)。当我按下 ctrl-c 时,收集会继续并继续在终端(或我重定向到的文件)中打印数据。

我在以下代码中做错了什么?

from threading import Thread
import time, sys, signal

shutdown_flag = False #used for gracefull shutdown

def main_loop():
    while not shutdown_flag:
        collect_data() # contains some print "data" statements
        time.sleep(5)
    print "done (killed)"

def sighandler(signum, frame):
    print 'signal handler called with signal: %s ' % signum
    global shutdown_flag
    shutdown_flag = True

def main(argv=None):
    signal.signal(signal.SIGTERM, sighandler) # so we can handle kill gracefully
    signal.signal(signal.SIGINT, sighandler) # so we can handle ctrl-c
    try:
        Thread(target=main_loop, args=()).start()
    except Exception, reason:
        print reason

if __name__ == '__main__':
    sys.exit(main(sys.argv))

最佳答案

您正在使用以下语句终止主线程:

if __name__ == '__main__':
    sys.exit(main(sys.argv))

所以你的信号处理程序永远不会运行。信号处理程序是主线程的一部分,而不是您创建的 main_loop 线程。所以一旦主线程退出,就没有信号处理函数可以调用了。

你需要这样的东西:
def sighandler(signum, frame):
    print 'signal handler called with signal: %s ' % signum
    global shutdown_flag
    shutdown_flag = True
    sys.exit() # make sure you add this so the main thread exits as well.

if __name__ == '__main__':
    main(sys.argv)
    while 1:  # this will force your main thread to live until you terminate it.
       time.sleep(1)

一个简单的测试来查看你的程序中有多少线程正在运行:
def main_loop():
    while not shutdown_flag:
        collect_data() # contains some print "data" statements
        time.sleep(5)
        import threading
        print threading.enumerate()
    print "done (killed)"

关于python - 为什么我的主线程中没有正确处理 signal.SIGTERM?,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/19988726/

10-11 22:31
查看更多