python使用asyncio内置库进行异步I/O

asyncio库

参考文章
asyncio库是python3.4后引入的标准库，其中直接内置了对异步IO的支持，asyncio的编程模型就是一个消息循环，咱们直接从asyncio中获取一个eventloop，而后把须要运行的协程扔到eventloop这个消息循环中，就实现了异步操做，下面是使用asyncio异步实现helloworld的过程（这是在async/await 语法糖没出来以前的写法，可能看起来有点复杂）

import asyncio

# 使用装饰器 将一个生成器变成协程
@asyncio.coroutine
def hello():
    print("hello world")
    # 这里的asyncio.sleep()就是在模拟IO操做
    r = yield from asyncio.sleep(1)
    print("hello again")

if __name__ == "__main__":
    #获取事件循环
    loop = asyncio.get_event_loop()
    #执行异步操做
    loop.run_until_complete(hello())
    #关闭事件池
    loop.close()

上面一段代码其实并无进行异步操做，可是能够进行，咱们向事件池中推入两个hello()封装的tasks列表，就是在进行异步操做了，

import asyncio
@asyncio.coroutine
def hello():
	print("hello world")
	r = yield from asyncio.sleep(1)
	print("hello again")

loop = asyncio.get_event_loop()
tasks = [hello(), hello()]
loop.run_until_complete(asyncio.wait(tasks))
loop.close()

这是执行结果

很明显，第二个hello函数没有等第一个函数返回hello again就开始返回hello world这说明咱们的异步操做成功了

可是能够看到，上述关于封装成协程类的操做有一些复杂，在python3.5中引入了async/await这一语法糖，因而咱们的代码能够简化为

import asyncio

async def hello():
	print("hello world")
	r = await asyncio.sleep(1)
	print("hello again")

loop = asyncio.get_event_loop()
tasks = [hello(), hello()]
loop.run_until_complete(asyncio.wait(tasks))
loop.close()