4

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

我想知道您如何检测客户端线程内的cherrypy关闭,以便在服务器关闭时线程可以中止。

我追求的是这样的:

class RootServer:
    @cherrypy.expose

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

1 回答 1

7

您可以直接检查状态:

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

如果您还希望在服务器启动时而不是在请求时启动冗长的进程(或执行一些准备),则后者特别有用。

于 2012-06-18T15:28:59.280 回答