求解Tornado gen.coroutine同步变异步的方法

跟着gen.coroutine走了N遍，源码也看过N遍了，yield generator实现coroutine的原理也了解，js callback也明白，但是问题是……

中，用官方的asyncHTTPclient可以实现异步加载，但，比如在sleep_bug里面加上了time.sleep(1)就整个线程阻塞了。

看网上的资料都说要改写function，添加上callback才能完成异步模式
可是PEP 3148（http://www.python.org/dev/peps/pep-3148/）里的例子没有一个是这种模式的，都有executor来完成，可tornado中没有，不知道怎么改gen.coroutine成异步了

coroutine

sleep

gen

11 条回复 • 2015-04-29 23:07:27 +08:00

est

2013 年 12 月 30 日

看文档 `IOLoop.add_timeout` is a non-blocking alternative to `time.sleep

mengzhuo

2013 年 12 月 30 日

@est 那怎么理解gen.coroutine -> Runner模式呢？

callback直接send给generator不就好了吗？

zenliver

2013 年 12 月 31 日

这里的异步是指io异步， time.sleep()会导致线程sleep，当然会阻塞线程了，正如@est所说， tornado有提供这样的功能，如果你遇到cpu bound问题，可以用tornado.concurrent.run_on_executor, backend用线程池还是进程池，还是其它什么，看你想怎么实现了，，，如果仅仅只是想把一个同步的程序变为异步，，，这么做没什么好处，，，，纯粹闲的蛋痛。。。。

mengzhuo

2013 年 12 月 31 日

@zenliver
不算是闲得慌
关键是js的callback/信号模式还能理解，写点小程序神马的都没问题，到Tornado上就傻眼了，future只是yield出来，后面又可以像同步的方法调用，但实际上又是异步的 OTZ

zenliver

2013 年 12 月 31 日

你看看Runner的实现，，，一切就明白了

b1074549

2014 年 2 月 13 日

ThreadedResolver

xunuoi

2015 年 3 月 9 日

用ThreadPoolExecutor来解决，举个例子：

from tornado import gen,web
from tornado.concurrent import run_on_executor
#if in Python2, it need install by pip install futures
from concurrent.futures import ThreadPoolExecutor

from model.Movie import Movie

class IndexHandler(web.RequestHandler):
executor = ThreadPoolExecutor(2)
@web.asynchronous
@gen.coroutine
def get(self): #用yield来返回一个迭代器函数
mov = yield self.query_movie()
self.write('llalalal')
self.finish()

@run_on_executor #此处是耗时的操作
def query_movie(self):
time.sleep(5)
return 'sleep lallal'

此时就是异步非阻塞的实现了（用线程解决的）

mengzhuo

2015 年 3 月 9 日

@xunuoi

虽然我已经搞懂了……而且用epoll自己实现了一些异步功能
但是还是谢谢回复哈

fasling

2015 年 4 月 28 日

@xunuoi 我也是用了这种方法,但是想在on_finish的时候对query_movie的返回值做做一些别的事情,请问要怎么做?

xunuoi

2015 年 4 月 29 日

@fasling 修饰器不行么？

fasling

2015 年 4 月 29 日

@xunuoi 不知道怎么搞啊?求教