最简单的例子tornado.gen

Question

我试图用Tornado's sync-style 'gen' tool运行一个简单的回声功能，在无阻塞风格：

import tornado.web 
import tornado.gen 
import logging 

def echo(message): 
    return message 

@tornado.gen.engine 
def runme(): 
    response = yield tornado.gen.Task(echo, 'this is a message') 
    logging.warn(response) 

runme() 

至于我可以告诉这个代码不显著不同的演示代码在文档中，减去不必要的请求处理程序的东西 - 我没有处理任何HTTP请求，AFAICT这是异步运行的东西是异步的。然而，这总是失败：

Traceback (most recent call last): 
    File "./server.py", line 46, in <module> 
runme() 
TypeError: wrapper() takes at least 1 argument (0 given) 

究竟我在哪里失踪的论点？我如何让Tornado异步运行此功能？

Answer 1

任务实际上并没有对正在运行的函数进行回调，并且在函数返回时开始回调，正如我原先所想的那样。

我需要创建任务的回调正在运行的自己，并调用它，即：

import tornado.web 
import tornado.gen 
import logging 

def echo(message, callback=None): 
    callback(message) 

@tornado.gen.engine 
def runme(): 
    response = yield tornado.gen.Task(echo, 'this is a message') 
    logging.warn(response) 

runme()