如何检测cherrypy是否正在关闭

Question

我已经制作了一个基于cherrypy的服务器,但我有一个重复的任务,需要很长时间(超过一分钟)才能运行.这一切都很好,直到我需要关闭服务器,然后我等待线程完成.

我想知道你如何在客户端线程中检测到cherrypy shutdown,以便线程可以在服务器关闭时中止.

我是这样的:

class RootServer:
    @cherrypy.expose

    def index(self, **keywords):
        for i in range(0,1000):
            lengthyprocess(i)
            if server_is_shutting_down():
                return

Answer 1

您可以直接检查状态:

if cherrypy.engine.state != cherrypy.engine.states.STARTED:
    return

或者,您可以在"停止"频道上注册听众:

class RootServer:

    def __init__(self):
        cherrypy.engine.subscribe('start', self.start)
        cherrypy.engine.subscribe('stop', self.stop)

    def start(self):
        self.running = True

    def stop(self):
        self.running = False

    @cherrypy.expose
    def index(self, **keywords):
        for i in range(0,1000):
            lengthyprocess(i)
            if not self.running:
                return

如果您还希望在服务器启动时启动(或执行一些准备工作),而不是根据请求,后者尤其有用.