python—协程

1、为什么要使用协程？

在执行A函数的时候，可以随时中断，去执行B函数，然后中断执行A函数（可以自动切换），注意这一过程并不是函数调用（没有调用语句），过程很像多线程，然而协程只有一个线程在执行。

2、协程的标准

：
a、必须在只有一个单线程里实现并发
b、修改共享数据不需要加锁
c、用户程序里自己保存多个控制流的上下文栈
d、一个协程遇到IO操作自动切换到其他协程

3、协程之Greenlet

from greenlet import greenlet


# 开发协程的案例，一个任务是回答，一个任务是问

def ask(name):
    print(f'{name}:你好啊')  # 2
    b.switch('吕布')  # todo answer函数第一次切换，需要传参
    print(f'{name}：今天学习了吗？')  # 4
    b.switch()


def answer(name):
    print(f'{name}：你也好啊')  # 3
    a.switch()
    print(f'{name}:必须的')


if __name__ == '__main__':
    # 创建2个协程
    a = greenlet(ask)  # 创建第1个协程
    b = greenlet(answer)  # 创建第2个协程
    a.switch('貂蝉')  # todo 每个函数只有在第一次切换的时候，才需要传参，后面不需要  UDP客户端

执行结果：

4、协程之Gevent

Gevent是一个第三方库，可以轻松通过gevent 实现并发同步或异步编程，在gevent中用到的主要模式是Greenlet，它是以C扩展模块形式接入Python的轻量级协程。Greenlet 全部运行在主程序操作系统进程的内部，但他们被协作式地调度。
当一个greenlet遇到O操作时，比如访问网络/睡眠等待，就自动切换到其他的greenlet，等到IO操作完成，再在适当的时候切换回来继续执行。由于I0操作非常耗时，经常使程序处于等待状态，有了gevent为我们自动切换协程，就保证总有greenlet在运行，而不是等待I0。同时也因为只有一个线程在执行，会极大的减少上下文切换的成本。
注意:上例gevent.sleep(2)模拟的是gevent可以识别的io阻塞;而time.sleep(2)或其他的阻塞,gevent,是不能直接识别的，需要加入一行代monkey.patch_all()，这行代码需在time，socket模块之前。

import gevent


# 开发协程的案例，一个任务是回答，一个任务是问

def ask(name):
    print(f'{name}:你好吖')
    gevent.sleep(1)  # todo 认为模拟io阻塞，阻塞1s
    print(f'{name}：今天学习了吗？')


def answer(name):
    print(f'{name}：你也好吖')
    gevent.sleep(1)
    print(f'{name}:必须的')


if __name__ == '__main__':
    # 创建2个协程
    a = gevent.spawn(ask, '小乔')  # todo 创建1个协程
    b = gevent.spawn(answer, '周瑜')  # todo 创建第2个协程
    gevent.joinall([a, b])  # todo 自动切换并行执行

执行结果：

5、协程之asyncio

import asyncio


async def func1():  # 定义一个协程
    for i in range(5):
        print('协程a！！！')
        await asyncio.sleep(1)  # 人为的模拟IO阻塞


async def func2():  # 定义一个协程
    for i in range(5):
        print('协程b！！！')
        await asyncio.sleep(2)


# todo 获取循环的事件
loop = asyncio.get_event_loop()

# todo 启动多个协程并行执行
loop.run_until_complete(asyncio.gather(func1(), func2()))

loop.close()