为什么龙卷风不会同时发生？

Question

以下是我的测试代码。我使用的是 Python2.7，安装了futures：

pip install futures

以下是我的演示代码：

import tornado.ioloop
import tornado.web
from tornado.gen import coroutine, Task
from tornado.concurrent import Future
import time


class MainHandler(tornado.web.RequestHandler):
    @coroutine
    def get(self):
        print "in"
        res = yield Task(self._work)
        self.write(res)

    def _work(self, callback):
        time.sleep(10)
        callback("hello world!")

if __name__ == "__main__":
    application = tornado.web.Application([
        (r"/", MainHandler),
    ])
    application.listen(8888)
    tornado.ioloop.IOLoop.instance().start()

这段代码应该同时运行，不是吗？然而，事实并非如此。

我用 Firefox 和 IE 进行了测试。我想我犯了一些错误。你能指出我的错误会很好。

一次只有一个请求(http://localhost:8888/:

import tornado.ioloop
import tornado.web
from tornado.gen import coroutine, Return, Task
from tornado.process import Subprocess
from tornado.concurrent import Future
from threading import Thread
import time

@coroutine
def async_sleep(timeout):
    """ Sleep without blocking the IOLoop. """
    yield Task(tornado.ioloop.IOLoop.instance().add_timeout, time.time() + timeout)

class MainHandler(tornado.web.RequestHandler):
    @coroutine
    def get(self):
        print "in"
        res = yield self._work()
        self.write(res)

    @coroutine
    def _work(self):
        yield async_sleep(5)
        raise Return("hello world!")

if __name__ == "__main__":
    application = tornado.web.Application([
        (r"/", MainHandler),
    ])
    application.listen(8888)
    ioloop=tornado.ioloop.IOLoop.instance()
    Thread(target=ioloop.start).start()

Answer 1

由于您在 cmets 中指出您希望通过 tornado 运行子进程，因此这里有一个示例说明如何执行此操作。我还修复了一个逻辑错误，即您在调用 _work 时创建了一个 Task，这不会按照您的预期方式工作：

import tornado.ioloop
import tornado.web
from tornado.gen import coroutine, Return
from tornado.process import Subprocess
from tornado.concurrent import Future

class MainHandler(tornado.web.RequestHandler):
    @coroutine
    def get(self):
        print "in"
        res = yield self._work()
        self.write(res)

    @coroutine
    def _work(self):
        p = Subprocess(['sleep', '10'])
        f = Future()
        p.set_exit_callback(f.set_result)
        yield f
        raise Return("hello world!")

if __name__ == "__main__":
    application = tornado.web.Application([
        (r"/", MainHandler),
    ])
    application.listen(8888)
    tornado.ioloop.IOLoop.instance().start()

如你所见，我将_work 做了一个协程，然后使用tornado's built-in Subprocess 类来执行一个命令。我创建了一个Future 对象，并指示Subprocess 在完成时调用Future.set_result(return_code_of_subprocess)。然后我在Future 实例上调用了yield。这使得代码等待子进程完成，而不会阻塞 I/O 循环。

Answer 2

您代码中的time.sleep 是一种阻塞方法。
你需要tornado.gen.sleep（一种非阻塞方法，tornado 4.1 中的新方法）来代替。