协程greenletyieldasyncioasync/await协程意义异步编程事件循环快速上手awaitTask对象

协程

协程(Coroutine)不是计算机提供&＃xff0c;程序员人为创造

协程也可以称为微线程, 是一种用户态的上下文切换技术。就是通过一个线程实现代码块相互切换执行。

实现协程方法&＃xff1a;

• greenlet
• yield
• asyncio 装饰器
• async/await 关键字

greenlet

pip install greenlet


from greenlet import greenletdef func1():print(1) # 2. 输出 1gr2.switch() # 3. 切换到 func2 函数print(2) # 6. 输出 2gr2.switch() # 7. 切换到 func2 函数&＃xff0c;从上一次执行位置向后执行def func2():print(3) # 4. 输出 3gr1.switch() # 5. 切换到 func1 函数&＃xff0c;从上一次执行位置向后执行print(4) # 8. 输出 4gr1 &＃61; greenlet(func1)
gr2 &＃61; greenlet(func2)gr1.switch() # 1. 执行 func1 函数


yield

def func1():yield 1yield from func2()yield 2def func2():yield 3yield 4for item in func1():print(item)


asyncio

python 3.4 之后支持

import asyncio&＃64;asyncio.coroutine
def func1():print(1)yield from asyncio.sleep(2)print(2)&＃64;asyncio.coroutine
def func2():print(3)yield from asyncio.sleep(2)print(4)tasks &＃61; [asyncio.ensure_future(func1()),asyncio.ensure_future(func2())
]loop &＃61; asyncio.get_event_loop()
loop.run_until_complete(asyncio.wait(tasks))


遇到 IO 阻塞自动切换

async / await

python 3.5 之后支持

import asyncioasync def func1():print(1)await asyncio.sleep(2)print(2)async def func2():print(3)await asyncio.sleep(2)print(4)tasks &＃61; [asyncio.ensure_future(func1()),asyncio.ensure_future(func2())
]loop &＃61; asyncio.get_event_loop()
loop.run_until_complete(asyncio.wait(tasks))


协程意义

一个线程中遇到 IO 等待时&＃xff0c;线程不会傻等&＃xff0c;利用空闲时间完成其他任务

异步编程

事件循环

事件循环的作用是管理所有的事件&＃xff0c;在整个程序运行过程中不断循环执行&＃xff0c;追踪事件发生的顺序将它们放到队列中&＃xff0c;当主线程空闲的时候&＃xff0c;调用相应的事件处理者来处理事件

快速上手

• 协程函数&＃xff1a;async def 函数名
• 协程对象&＃xff1a;执行 协程函数() 得到协程对象

async def func():pass# 执行协程函数得到协程对象&＃xff0c;函数内部代码不会执行
result &＃61; func()


# 想要运行协程函数内部代码&＃xff0c;必须要将协程对象交给事件循环处理async def func():print(&＃39;test&＃39;)res &＃61; func()loop &＃61; asyncio.get_event_loop()
loop.run_until_complete(res)# py3.7&＃43;
asyncio.run(res)


await

await &＃43; 可等待的对象 (协程对象, Future, Task对象) IO等待

async def test():print(&＃39;test&＃39;)res &＃61; await asyncio.sleep(2)


Task对象

Tasks 用于并发调度协程&＃xff0c;通过 asyncio.create_task(协程对象) 的方式创建 Task 对象&＃xff0c;这样可以让协程加入事件循环中等到被调度执行

# Example 1
async def test():print(&＃39;test satart...&＃39;)await asyncio.sleep(2)async def main():print(&＃39;start...&＃39;)task1 &＃61; asyncio.create_task(test())task2 &＃61; asyncio.create_task(test())await task1await task2asyncio.run(main())# start...
# test satart...
# test satart...# sleep 2


# Example 2
async def test():print(&＃39;test satart...&＃39;)await asyncio.sleep(1)return &＃39;1&＃39;async def main():tasks &＃61; [asyncio.create_task(test()),asyncio.create_task(test()),]await asyncio.wait(tasks)asyncio.run(main())