tornado框架的异步查询语法

Tornado是一个轻量级、事件驱动的Web服务器框架，特别适合用于构建高并发的网络应用。它的异步查询通常通过`tornado.gen.coroutine`装饰器和`yield`关键字来实现非阻塞式I/O操作。

在Tornado中，你可以这样编写异步数据库查询：

import tornado.ioloop
from tornado.concurrent import run_on_executor
from tornado.escape import json_decode
from tornado_sqlalchemy import Session

class AsyncHandler(tornado.web.RequestHandler):
    @run_on_executor
    def get_user(self, user_id):
        session = Session()
        result = yield session.query(User).get(user_id)
        # 使用yield表达式确保不会阻塞主线程
        return result

    def get(self, user_id):
        self.get_user(user_id)  # 调用时并不立即执行，而是添加到IOLoop的任务队列中
        self.write(json_encode(self.result))  # 当异步任务完成时，结果会被自动更新到self.result

# ...其他处理...

if __name__ == "__main__":
    app = tornado.web.Application(handlers...)
    app.listen(8888)
    tornado.ioloop.IOLoop.current().start()

在这里，`get_user`方法上标注了`@run_on_executor`，表示这个方法会在单独的线程池中执行，而不会阻塞HTTP请求的响应。当查询完成后，`yield`会返回结果给调用者，然后在`get`方法中直接使用。