单个Tornado RequestHandler
类是否可以在等待Future
在其某个实例中完成时处理新请求?
我正在调试一个名为ThreadPoolExecutor
的Tornado协程,我注意到,当协程等待执行器完成时,RequestHandler
被阻塞了。因此,对这个处理程序的任何新请求都在等待协程完成。
以下是我为重现我的观察结果而写的代码:
from time import sleep
from concurrent.futures import ThreadPoolExecutor
from tornado.ioloop import IOLoop, PeriodicCallback
from tornado.web import Application, RequestHandler
from tornado.gen import coroutine
class Handler1(RequestHandler):
@coroutine
def get(self):
print('Setting up executor ...')
thread_pool = ThreadPoolExecutor(1)
print('Yielding ...')
yield thread_pool.submit(sleep, 30)
self.write('Ready!')
print('Finished!')
app = Application([('/1$', Handler1)])
app.listen(8888)
PeriodicCallback(lambda: print('##'), 10000).start()
IOLoop.instance().start()
现在,如果我访问localhost:8888/1
两次,我会得到以下输出:
##
Setting up executor ...
Yielding ...
##
##
##
Finished!
Setting up executor ...
Yielding ...
##
##
##
Finished!
##
但我预计会发生以下情况:
##
Setting up executor ...
Yielding ...
Setting up executor ...
Yielding ...
##
##
##
Finished!
Finished!
##
请注意,似乎只有RequestHandler
被阻塞,因为我们仍然每10秒获得一次##
。事实上,如果您添加另一个相同的RequestHandler
(Handler2)并访问localhost:8888/1
和localhost:8888/2
,这将产生预期的输出。
这正常吗?这是预期行为吗?
抱歉我英语不好。
Tornado为每个新请求创建一个新的RequestHandler实例。因此,您的代码确实如您所期望的那样运行。我运行它并打开两个终端窗口,每个窗口都运行wget localhost:8888/1
。您的代码打印:
Setting up executor ...
Yielding ...
Setting up executor ...
Yielding ...
##
##
##
Finished!
Finished!
正如你所期望的。您可能看到的是,您的浏览器不愿意同时打开同一URL的两个连接。事实上,如果我打开两个选项卡并尝试在这两个选项卡中加载"localhost:8888/1",我可以重现您在chrome中看到的"阻塞"行为。但是,如果我修改你的代码:
app = Application([
('/1$', Handler1),
('/2$', Handler1)])
在Chrome的两个选项卡中打开"localhost:88888/1"one_answers"localhost:8888/2",我看到它同时打开了这两个连接。
尝试wget在不受浏览器干扰的情况下进行测试。
也适用于我:
$ curl http://127.0.0.1:8888/1 &
[1] 95055
$ curl http://127.0.0.1:8888/1 &
[2] 95056
$ curl http://127.0.0.1:8888/1 &
[3] 95057
龙卷风程序输出:
bash-3.2$ python3 test.py
##
##
Setting up executor ...
Yielding ...
Setting up executor ...
Yielding ...
Setting up executor ...
Yielding ...
##
##
##
Finished!
Finished!
Finished!
##
##
##