10

好吧,我希望cherrypy 在自动重新加载时杀死所有子线程,而不是“等待子线程终止”,因为我的程序有自己的线程,我不知道如何解决这个问题。CherryPy 一直挂在那一行上,我不知道该怎么做才能让“子线程”终止......

`

[05/Jan/2010:01:14:24] ENGINE HTTP Server cherrypy._cpwsgi_server.CPWSGIServer(('127.0.0.1', 8080)) shut down
[05/Jan/2010:01:14:24] ENGINE Stopped thread '_TimeoutMonitor'.
[05/Jan/2010:01:14:24] ENGINE Bus STOPPED
[05/Jan/2010:01:14:24] ENGINE Bus EXITING
[05/Jan/2010:01:14:24] ENGINE Bus EXITED
[05/Jan/2010:01:14:05] ENGINE Waiting for child threads to terminate...

`

它永远不会继续......所以我想强制子线程关闭......

我知道这是因为我的应用程序正在使用它自己的线程,我猜cherrypy 希望这些线程与 CherryPy 的......我可以克服这个问题吗?

4

2 回答 2

14

您需要编写停止线程的代码,并将其注册为“停止”事件的侦听器:

from cherrypy.process import plugins

class MyFeature(plugins.SimplePlugin):
    """A feature that does something."""

    def start(self):
        self.bus.log("Starting my feature")
        self.threads = mylib.start_new_threads()

    def stop(self):
        self.bus.log("Stopping my feature.")
        for t in self.threads:
            mylib.stop_thread(t)
            t.join()

my_feature = MyFeature(cherrypy.engine)
my_feature.subscribe()

有关详细信息,请参阅http://www.cherrypy.org/wiki/BuiltinPluginshttp://www.cherrypy.org/wiki/CustomPlugins

于 2010-01-05T16:48:50.737 回答
0

这适用于快速入门

def stopit():
    print 'stop handler invoked'
    #...
stopit.priority = 10
cherrypy.engine.subscribe('stop', stopit)

为了支持其生命周期,CherryPy 定义了一组公共通道,这些通道将在各种状态下发布:

“start”:当总线处于“STARTING”状态时

“main”:周期性地来自 CherryPy 的主循环

“stop”:当总线处于“STOPPING”状态时

“优雅”:当总线请求重新加载订阅者时

“exit”:当总线处于“EXITING”状态时

该频道将由引擎自动发布。因此,注册任何需要对引擎的转换更改做出反应的订阅者。

..

为了与总线一起工作,实现提供了以下简单的 API:

cherrypy.engine.publish(频道,*args):

通道参数是一个字符串,标识消息应该发送到的通道

*args 是消息,可能包含任何有效的 Python 值或对象。

cherrypy.engine.subscribe(频道,可调用)

通道参数是一个字符串,用于标识可调用将注册到的通道。

callable 是一个 Python 函数或方法,其签名必须与将要发布的内容相匹配。

于 2013-08-09T08:36:01.783 回答