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

[mengzhuo]

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

https://gist.github.com/mengzhuo/8178355

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

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

[est]

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

[mengzhuo]

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

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

[zenliver]

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

[mengzhuo]

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

[zenliver]

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

[b1074549]

ThreadedResolver

[xunuoi]

用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]

@xunuoi

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

[fasling]

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

[xunuoi]

@fasling 修饰器不行么？

[fasling]

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