在哪里加入异步龙卷风请求处理程序中创建的线程？

Question

这个让我有点困惑。对 python 中的龙卷风和线程相当陌生，所以我可能完全偏离了我在这里尝试做的事情。

可能最好从一些简化的代码开始：

class Handler(tornado.web.RequestHandler):

  def perform(self):
     #do something cuz hey, we're in a thread!

  def initialize(self):
    self.thread = None

  @tornado.web.asynchronous
  def post(self):

    self.thread = threading.Thread(target=self.perform)
    self.thread.start()

    self.write('In the request')
    self.finish()

  def on_connection_close(self):
    logging.info('In on_connection_close()')
    if self.thread:
      logging.info('Joining thread: %s' % (self.thread.name))
      self.thread.join()

我的问题是 on_connection_close 永远不会被调用，请求得到很好的处理。其次，我以这种方式引入线程是不是做了一些可怕的事情？

Answer 1

我相信 Thread.join() 会阻塞直到线程完成，这可能是您想要避免的事情。您可以让线程回调处理程序，而不是加入。

使用线程时，请注意，tornado 不是线程安全的，因此您不能使用线程中的任何 RequestHandler（例如）方法。

这对我有用：

import functools
import time
import threading
import logging

import tornado.web
import tornado.websocket
import tornado.locale
import tornado.ioloop

class Handler(tornado.web.RequestHandler):
    def perform(self, callback):
        #do something cuz hey, we're in a thread!
        time.sleep(5)
        output = 'foo'
        tornado.ioloop.IOLoop.instance().add_callback(functools.partial(callback, output))

    def initialize(self):
        self.thread = None

    @tornado.web.asynchronous
    def get(self):
        self.thread = threading.Thread(target=self.perform, args=(self.on_callback,))
        self.thread.start()

        self.write('In the request')
        self.flush()

    def on_callback(self, output):
        logging.info('In on_callback()')
        self.write("Thread output: %s" % output)
        self.finish()

application = tornado.web.Application([
    (r"/", Handler),
])

if __name__ == "__main__":
    application.listen(8888)
    tornado.ioloop.IOLoop.instance().start()

您可以使用curl --no-buffer localhost:8888 进行测试。有些浏览器（Safari）似乎要等待连接关闭才能显示任何输出，这让我有一段时间感到困惑。

Answer 2

AFAIK，仅当客户端终止连接时才会调用 on_connection_close ，这可能可以解释您的问题。
关于线程，我不知道你想做什么，但我不明白为什么你想在 Tornado 请求中创建一个线程，因为 Tornado 的优点之一就是你不必使用线程。
如果我要在您的示例中添加 join ，我会将其放在 self.finish() 之前，但是，您可能可以忽略它......这将取决于你想用线程做什么，但请记住，Tornado 是单线程的，如果在 join() 到来时线程尚未完成，整个过程将被阻塞。