Extending tornado.gen.Task

Question

这是一个愚蠢的websocket时钟的有趣部分:

class StupidClock(websocket.WebSocketHandler):
    clients = {}
    @web.asynchronous
    @gen.coroutine
    def open(self):
        self.is_open = True
        def enqueue(callback=None):
            self.__class__.clients[self] = callback
        while self.is_open:
            # This is the most interesting part!
            msg = yield gen.Task(enqueue)
            self.write_message(msg)
    def on_close(self):
        self.is_open = False
        del self.__class__.clients[self]
    @classmethod
    def periodic_update(cls):
        msg = time.time()
        # copy and clear before iterating to avoid infinite growth!
        clients = cls.clients.copy()
        cls.clients.clear()
        for obj, callback in clients.items():
            if obj.is_open:
                callback(msg)
# all the routing and application setup omitted...
loop = ioloop.IOLoop.instance()
cb = ioloop.PeriodicCallback(StupidClock.periodic_callback, 1,
                             io_loop=loop)
cb.start()
loop.start()

我的问题是关于解构这个语句的:

msg = yield gen.Task(enqueue)

从文档来看，它与:

相同

result = yield gen.Task(func, args)
# is the same as
func(args, callback=(yield gen.Callback(key)))
result = yield gen.Wait(key)

我很清楚第一个形式(只有一个yield表达式)发生了什么，但为什么我必须放弃控制龙卷风创建一个gen.Callback对象?

一个单独的yield表达式如何等价于两个yield表达式?不要对龙卷风控制屈服两次?然而，在gen.Task形式中，我只放弃一次控制权!

Answer 1

当你调用yield gen.Callback时，它会短暂地将控制转移到Tornado，但Tornado会立即返回到你的代码。它只是一种不使用全局(或线程局部)变量与协程调度器通信的方法。它使用这种奇怪的模式，所以它可以与gen模块之前的库一起工作，并且对协程一无所知。对于较新的代码(自Tornado 3.0以来)，推荐的模式是异步函数返回Future(如果使用@gen.coroutine，则会自动发生)，这使得它们可以在没有gen.Task或gen.Callback的协程中使用。