python异步并发框架

这里说“类似”，是因为实际情况要比这复杂很多，但意思是一样的：将内层迭代器的元素无缝地合并到外层的迭代器里。有了这个，asyncio 就可以很容易地做微线程的嵌套了——也就是在一个微线程里面等待另一个结束返回结果。

asyncio 作为又一个异步并发框架，与其他现有框架差别并不大：主循环类似于 Twisted 的 reactor，Future 对回调函数进行封装类似于 Deferred，可选的微线程类似于 inlineCallbacks，基于 yield from 的显式的异步切换类似于 yield，这里就不多介绍了，总的来看非常像 Twisted。但是呢，它能进入标准库，还是有原因的。

asyncio 作为参考实现，与其规格文档 PEP 3156 是一起做出来的，蟒爹在做的过程中尤其关注了互操作性。

比如 asyncio 的主循环就是可以任意替换的，任何满足 asyncio 主循环接口要求的核心都可以被安装上去。为了做到这一点，PEP 3156 定义了严格的主循环接口，将 asyncio 的框架代码部分与主循环核心完全分离。这样一来，许多现有框架加个壳就可以支持 asyncio 了——不用改现有代码，写一个现有主循环接口到 asyncio 主循环接口的适配层，替换掉 asyncio 自带的主循环，这样 asyncio 的代码就可以跑在现有框架上面了。

另一个方向也是行得通的。PEP 3156 同样定义了丰富而清晰的用户接口，我们可以使用这些接口来实现一个现有框架的主循环替代品，这样就可以在不替换 asyncio 已有主循环的前提下，将别的框架的代码嫁接到 asyncio 上来。比如说我的 gevent3 就是这么一个例子，我将 Gevent 中原有的 libev 代码删掉，用 asyncio 实现了一份 Gevent Hub，这样，gevent 的代码就可以跑在 asyncio 框架上了。更令人兴奋的是，如果 asyncio 使用的主循环核心又恰好是比如说 Twisted，那么原先分别依赖 Gevent 和 Twisted 的代码，现在就可以跑在一起了，甚至互相调用也是可以的。

比如下面一段示例代码就演示了三个框架的融合：

import asyncio
import gevent  ## gevent3
import Redis
from gevent import socket
from redis import connection
from twisted.web import server, resource
from twisted.internet import reactor
 
 
asyncio.set_event_loop(some_twisted_wrapper)
 
 
class GreenInetConnection(connection.Connection):
    def _connect(self):
        #noinspection PyUnresolvedReferences
        sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
        sock.settimeout(self.socket_timeout)
        sock.connect((self.host, self.port))
        return sock
 
 
class HelloResource(resource.Resource):
    isLeaf = True
 
    def render_GET(self, request):
        gevent.spawn(self.green_GET, request)
        return server.NOT_DONE_YET
 
    def green_GET(self, request):
        r = redis.StrictRedis(
            connection_pool=connection.ConnectionPool(
                connection_class=GreenInetConnection))
        numberRequests = r.incr("numberRequests")
        request.setHeader("content-type", "text/plain")
        request.write("I am request #" + str(numberRequests) + "\n")
        request.finish()
 
 
reactor.listenTCP(8080, server.Site(HelloResource()))
asyncio.run_forever()