Python中Tornado协程的使用详解（附实例）

使用Tornado协程可以开发出类似同步代码的异步行为。同时，因为协程本身不使用线程，所以减少了线程上下文切换的开销，是一种高效的开发模式。

1、编写协程函数

实例：用协程技术开发网页访问功能

#用协程技术开发网页访问功能from tornado import  gen #引入协程库genfrom tornado.httpclient import AsyncHTTPClientimport time#使用gen.coroutine修饰器@gen.coroutinedef coroutine_visit():    http_client=AsyncHTTPClient()    response=yield http_client.fetch("http://www.baidu.com")    print(response.body)

本例中任然使用了异步客户端AsyncHTTPClient进行页面访问，装饰器@gen.coroutine声明这是一个协程函数，由于yield关键字的作用，使得代码中不用再编写回调函数用于处理访问结果，而可以直接在yield语句的后面编写结果处理语句。

2、调用协程函数

由于Tornado协程基于Python的yield关键字实现，所以不能像普通函数那样直接调用。
协程函数可以通过以下三张方式调用：

• 在本身是协程的函数内通过yield关键字调用。

• 在IOLoop尚未启动时，通过IOLoop的run_sync()函数调用。

• 在IOLoop已经启动时，通过IOLoop的spawn_callback()函数调用。

实例：通过协程函数调用协程函数

代码：

#用协程技术开发网页访问功能from tornado import  gen #引入协程库genfrom tornado.httpclient import AsyncHTTPClientimport time#使用gen.coroutine修饰器@gen.coroutinedef coroutine_visit():    http_client=AsyncHTTPClient()    response=yield http_client.fetch("http://www.baidu.com")    print(response.body)@gen.coroutinedef outer_coroutine():    print("start call coroutine_visit")    yield coroutine_visit()    print("end call coroutine_cisit")

本例中outer_coroutine()和coroutine_visit()都是协程函数，所以他们之间可以通过yield关键字调用。_

实例：IOLoo尚未启动时，通过IOLoop的run_sync()函数调用。

IOLoop是Tornado的主事件循环对象，Tornado程序通过它监听外部客户端的访问请求，并执行相应操作。

代码：

#用协程技术开发网页访问功能from tornado import  gen #引入协程库genfrom tornado.httpclient import AsyncHTTPClientfrom tornado.ioloop import IOLoop  #引入IOLoop对象#使用gen.coroutine修饰器@gen.coroutinedef coroutine_visit():    http_client=AsyncHTTPClient()    response=yield http_client.fetch("http://www.baidu.com")    print(response.body)def func_normal():    print("start call coroutine_visit")    IOLoop.current().run_sync(lambda :coroutine_visit())   <div>本文来源gaodai^.ma#com搞#代!码网</div> print("end call coroutine_visit")

当程序尚未进入IOLoop的running状态时，可以通过run_sync()函数调用协程函数。

注意：run_sync()函数将阻塞当前函数的调用，直到被调用的协程执行完成。

事实上，Tornado要求协程函数在IOLoop的running状态种才能被调用，只不过run_sync函数自动完成了启动、停止IOLoop的操作步骤，他的实现逻辑是：

【启动IOLoop】》【调用被lambda封装的协程函数】》【停止IOLoop】

实例：在IOLoop启动时，通过spawn_callback()函数调用

代码：

#用协程技术开发网页访问功能from tornado import  gen #引入协程库genfrom tornado.httpclient import AsyncHTTPClientfrom tornado.ioloop import IOLoop  #引入IOLoop对象#使用gen.coroutine修饰器@gen.coroutinedef coroutine_visit():    http_client=AsyncHTTPClient()    response=yield http_client.fetch("http://www.baidu.com")    print(response.body)def func_normal():    print("start call coroutine_visit")    IOLoop.current().spawn_callback(coroutine_visit)    print("end call coroutine_visit")

喜欢 (0)赏

[搞代码]

分享 (0)