为什么龙卷风异步不起作用

Question

今天，当我想让一些同步 Python 库异步运行时，它不起作用。经过一系列的测试，我发现即使yield tornado.gen.sleep(N)也能同步运行。

这是我的代码：

import time
import tornado.web
import tornado.gen
import tornado.ioloop
import os


class MainHandler(tornado.web.RequestHandler):
    def get(self):
        self.render("test.htm")


class SleepHandler(tornado.web.RequestHandler):
    def get(self):
        time.sleep(2)
        self.write("Good morning!")


class YSleepHandler(tornado.web.RequestHandler):
    @tornado.gen.coroutine
    def get(self):
        yield tornado.gen.sleep(2)
        self.write("Good morning!")


def main():
    app = tornado.web.Application([
        (r"/sleep", SleepHandler),
        (r"/ysleep", YSleepHandler),
        (r"/", MainHandler),
        ], debug=True, template_path=os.path.split(
            os.path.realpath(__file__))[0])
    app.listen(8888)
    try:
        tornado.ioloop.IOLoop.current().start()
    except:
        tornado.ioloop.IOLoop.current().stop()


if __name__ == "__main__":
    main()

我使用下面的代码来测试异步函数是否有效（在 test.htm -- MainHandler 的模板文件中）：

for(var i = 0; i < 10; i++){
                $.get("/sleep");
            }
for(var i = 0; i < 10; i++){
                $.get("/ysleep");
            }

但最后，我得到了一个意想不到的result。

怎么了？我在Python2.7和Python3.4环境下都试过了。

Answer 1

最后，通过在 URL 末尾添加一些独特的无用参数来解决这个问题。

for(var i = 0; i < 10; i++){
                $.get("/sleep");
            }
for(var i = 0; i < 10; i++){
                $.get("/ysleep");
            }

如果您使用上面的代码测试结果，您将收到与使用同步代码相同的结果（因为 tornado 将返回 304 未修改，这是一个同步函数。）。但是如果使用下面的代码，同步和异步之间的区别将完全说明。

for(var i = 0; i < 10; i++){
                $.get("/sleep", {"random": Math.random()});
            }
for(var i = 0; i < 10; i++){
                $.get("/ysleep", {"random": Math.random()});
            }

Answer 2

您看到这种行为是因为 yield 在协程中有效地将控制权转移回 Tornado 的 IOLoop。这并不意味着它将结果返回给客户端 - 只是将控制权返回给 Tornado，这样 IOLoop 就不会被长时间运行的请求阻塞。

这对您的代码的影响是 Tornado 将在 SleepHandler 运行时阻塞，而在 YSleepHandler 运行时它不会阻塞。在这两种情况下，只有当您的处理程序调用 self.write() 时才会将响应返回给客户端，但在 YSleepHandler 的情况下，可以在处理程序运行时处理其他请求，因为 IOLoop 是没有被屏蔽。