Tornado 使用 Future 对象

Tornado 使用 tornado.concurrent.Future 对象来实现异步操作。Future 是 Tornado 中用于表示尚未完成的操作的对象，它可以在异步编程中用于处理异步任务的结果。

以下是一个简单的示例，演示如何在 Tornado 中使用 Future 对象：

import tornado.ioloop
import tornado.web
from tornado.concurrent import Future

class MainHandler(tornado.web.RequestHandler):
    def get(self):
        # 创建一个 Future 对象
        future = Future()

        # 模拟异步操作
        tornado.ioloop.IOLoop.current().add_timeout(tornado.ioloop.IOLoop.current().time() + 2, lambda: future.set_result("Hello, Tornado Future!"))

        # 在 Future 对象上添加回调
        future.add_done_callback(self.on_future_done)

        self.write("Waiting for the result...")

    def on_future_done(self, future):
        # 当 Future 对象完成时调用的回调函数
        result = future.result()
        self.write("Result: {}".format(result))
        self.finish()

def make_app():
    return tornado.web.Application([
        (r"/", MainHandler),
    ])

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

在这个示例中，MainHandler 的 get 方法创建了一个 Future 对象，并模拟了一个异步操作，通过 tornado.ioloop.IOLoop.current().add_timeout 来延迟2秒钟后设置 Future 的结果。然后，通过 future.add_done_callback 添加了一个回调函数，在 Future 完成时被调用。

on_future_done 方法是 Future 完成时被调用的回调函数，它获取 Future 的结果并输出到客户端。

在实际应用中，Future 对象通常是通过异步框架或库返回的，用于表示异步操作的结果。它可以作为异步编程中的一种模式，帮助处理异步任务的结果和回调。

转载请注明出处：http://www.pingtaimeng.com/article/detail/7453/Tornado