from gevent import monkey; # 为了能识别time模块的io
monkey.patch_all()  #必须放到被打补丁者的前面，如 time，socket 模块之前
import gevent
# pip install gevent
from time import time,sleep

def gf(name):
    print(f'{name}:我想打王者！！')
    # gevent.sleep(2)
    sleep(2)
    print(f'{name}:我想吃大餐！！！')

def bf(name):
    print(f'{name}:一起打！！！')
    # gevent.sleep(2)
    sleep(2)
    print(f'{name}:一快去吃！！')

if __name__ == "__main__":
    start = time()
    # 创建协程对象
    g1 = gevent.spawn(gf,'貂蝉')
    g2 = gevent.spawn(bf,'吕布')

    # 开启任务
    g1.join()
    g2.join()
    end = time()
    print(end-start)

注意：上例 gevent.sleep(2)模拟的是 gevent 可以识别的 io 阻塞;

而 time.sleep(2)或其他的阻塞,gevent 是不能直接识别的需要用下面一行代码,打补丁,就

可以识别了

asyncio 是 python3.4 之后的协程模块，是 python 实现并发重要的包，这个包使用事件

循环驱动实现并发。

事件循环是一种处理多并发量的有效方式，在维基百科中它被描述为「一种等待程序分配

事件或消息的编程架构」，我们可以定义事件循环来简化使用轮询方法来监控事件，通俗的说

法就是「当 A 发生时，执行 B」。

@asyncio.coroutine 协程装饰器装饰

asyncio.sleep() 可以避免事件循环阻塞

get_event_loop() 获取事件循环

?Loop.run_until_complete() 监听事件循环

?gather() 封装任务

await 等于 yield from 就是在等待 task 结果

import asyncio
@asyncio.coroutine # python3.5 之前 官网说3.10将被移除
def func1():
    for i in range(5):
        print('一边吃饭！！')
        yield from asyncio.sleep(0)

async def func2(): # python3.5以上
    for i in range(5):
        print('一边打游戏！！！')
        await asyncio.sleep(0)
if __name__ == "__main__":
    g1 = func1()
    g2 = func2()
    # 获取事件循环
    loop = asyncio.get_event_loop()
    # 监听事件循环
    loop.run_until_complete(asyncio.gather(g1,g2))
    # 关闭事件循环
    loop.close()

1、asyncio中的task的使用

import asyncio
import functools
async def compute(x,y):
    print(f'compute:{x}+{y}....')
    await asyncio.sleep(1)
    return x+y


async def print_sum(x,y):
    # 创建task
    task = asyncio.create_task(compute(x,y))        #python3.7以上写法
    # task绑定回调函数
    task.add_done_callback(functools.partial(end,x,y))  #python3.7以上写法
    # 释放下cpu的使用
    await asyncio.sleep(0)
    print('--------------------print_num继续执行---------------------------')
    for i in range(1000000):
        if i%5000 ==0:
            print(i)
            await asyncio.sleep(0.1)

def end(n,m,t):
    print(f'{n}+{m}={t.result()}')

if __name__ == "__main__":
    loop = asyncio.get_event_loop()

    loop.run_until_complete(print_sum(1,2))

    loop.close()

五、总结