python - Tornado 的异步请求机制-PHP中文网问答

文章专题 AI工具学习下载问答源码最近更新

PHP

会员中心讲师中心微信公众号

python - Tornado 的异步请求机制

黄舟 2017-04-17 13:39:54

[Python讨论组]

308

假设有如下代码.

class Index(RequestHandler):

    @coroutine
    def get(self):
        response = yield AsyncHTTPClient().fetch('google.com')
        print(response)

这个代码通过 AsyncHTTPClient 异步的获取某些内容.

问题是:

AsyncHTTPClient 获取内容的时候, Tornado 是不是离开这个 Handler 去处理其它事情了?
那么谁来执行 AsyncHTTPClient 的内容呢? 再开一个线程吗? 再开一个线程的话, 那不是每一个请求都要新建一个线程了吗= _ =....

谢谢.

黄舟

人生最曼妙的风景，竟是内心的淡定与从容！

全部回复(3)

天蓬老师2017-04-17 13:41:54 3楼

首先，你的程序是错误的。应该这么写：

class Index(RequestHandler):
    @coroutine
    def get(self):
        response = yield AsyncHTTPClient().fetch('http://google.com')
        print(response)

Tornado 是异步网络库。它意味着，有网络 I/O 事件时它才会相应地处理。

一个简单的比喻，你去餐厅吃饭，服务员把菜单给你们就走了，处理其它事务去了；你这边准备点菜了，再把它叫过来。

Tornado 的机制是类似的：在抓取网页时，Tornado 将请求发出，然后告诉操作系统，在这个连接上有数据时通知一下。然后它就去忙其它事务了，比如响应另一个请求。

除非你程序里自己开线程，否则 Tornado 是单线程的。

赞 +0

添加回复

怪我咯2017-04-17 13:41:54 2楼

可能答非所问了，但我都是这么干的：

class MyHandler(tornado.web.RequestHandler):
  # 线程池
  executor = ThreadPoolExecutor(max_thread_num)

  # 线程里处理
  @run_on_executor
  def my_func(self, data):
    # do something with data
    return data

  @tornado.web.asynchronous
  @tornado.gen.coroutine
  def get(self):
    # 获取各种参数
    res = yield self.my_func()
    self.write(str(res))
    self.finish()

赞 +0

添加回复