龙卷风优雅地关闭IOLoop

Question

我正在使用以下代码优雅地关闭我的龙卷风应用程序(取自https://gist.github.com/wonderbeyond/d38cd85243befe863cdde54b84505784):

def sig_handler(servers, sig, frame):
    io_loop = tornado.ioloop.IOLoop.instance()

    def stop_loop(deadline):
        now = time.time()
        if now < deadline and (io_loop._callbacks or io_loop._timeouts):
            logging.info('Waiting for next tick')
            print("CALL BACKS")
            print(io_loop._callbacks)
            print("TIMEOUTS")
            print(io_loop._timeouts)
            io_loop.add_timeout(now + 1, stop_loop, deadline)
        else:
            io_loop.stop()
            logging.info("Shutting down.")

    def shutdown():
        logging.info("Stopping http servers")

        # servers is a list of servers to stop
        for s in servers:
           s.stop()

        logging.info("Will shutdown in %s seconds ...",
                     MAX_WAIT_SEC_BEFORE_SHUTDOWN)
        stop_loop(time.time() + MAX_WAIT_SEC_BEFORE_SHUTDOWN)

    logging.warning("Caught signal: %s", sig)
    io_loop.add_callback_from_signal(shutdown)

我将MAX_WAIT_SEC_BEFORE_SHUTDOWN设置为10秒.即使在关闭http服务器之后,每次都需要整整10秒来关闭服务器.我注意到io_loop._timeouts列表中总有一些项目例如:

[<tornado.ioloop._Timeout object at 0x106b90408>, <tornado.ioloop._Timeout object at 0x106b904c8>, ...]

有什么项目io_loop._timeouts？我应该期待这是一个空列表还是我不能阻止我应该拥有的东西？

这个关闭程序是否正常？谁能建议其他代码？

Answer 1

停止 TornadoHTTPServer不会关闭所有现有连接，它只会阻止服务器接受新连接。有一个未记录的close_all_connections方法，但它不区分空闲连接和当前正在处理请求的连接，因此不适合在正常关闭中使用。当前没有任何方法可以在所有连接空闲时关闭它们。

每个空闲连接都会在 IOLoop 上维护一个超时（如果空闲时间太长，连接将被关闭，尽管默认值为一小时。传递idle_connection_timeout=给HTTPServer构造函数来更改此设置）。此外，Tornado 或其他库的其他功能也可能会创建超时（在 Tornado 本身中，curl_httpclient并且autoreload两者都会创建始终运行的超时），因此您通常不能假设待处理超时的数量将达到零。

总的来说，我建议只是无条件等待，MAX_WAIT_SEC_BEFORE_SHUTDOWN而不是试图确定是否可以安全地尽早关闭。如果您确实想确定所有挂起操作何时完成，那么最好自己保留挂起操作的计数（对于您认为合适的“操作”的任何定义），而不是尝试从IOLoop.