0

我正在编写一个龙卷风网络服务器,并试图阻止它阻塞一个功能。

class TokenHandler(tornado.web.RequestHandler):
    @tornado.web.asynchronous
    def post(self):
        global t
        email = self.get_argument("text")
        thread = MetaToken.ExeThread(email,t,self._on_response)
        thread.start()
        #data = t.analyze(email)


    def _on_response(self,json):
        self.write(json)
        self.finish()

分析在 t 中调用,可能需要几秒钟才能完成。只要可以同时处理其他客户的请求,我就可以了。这在大多数情况下都有效,但会在流关闭的某些连接上引发错误。

4

1 回答 1

0

不要以这种方式在龙卷风中使用线程!

如果您有需要线程的繁重任务,请使用celery。如果任务很轻 - 只需将其交给gen

于 2012-06-27T09:02:20.153 回答