Python3协程（coroutine）理解

枫铃3年前 (2021-09-30)Python224

一、背影说明

最早开始接解协程应该是看到requests库代码里有await的字眼，接下来曾多次尝试理解协程怎么用，但都失败了。

主要的问题是很多文章上来就是告诉你生成器是什么、原理是什么，我一直觉得原理这东西深入理解时是应该的，但是我作为一个小白我不希望你跟我讲原理，我没耐心也听不懂。

我只希望你告诉我协程有什么用效果是什么、我该怎么调用。

今天又去看了一下，有些理解，但不一定准确，为了下次不重头再来，暂且先记一记。

二、协程代码实现

2.1 协程函数的定义

正常函数怎么写就怎么写，在def前面加上async即可。如：

async def say_after(delay, what):
    await asyncio.sleep(delay)
    print(what)

2.2 协程函数的调用

入口函数使用asyncio.run() 进行调用。如：

import asyncio

async def main():
    print(f"started at {time.strftime('%X')}")

    print('hello world!')

    print(f"finished at {time.strftime('%X')}")

if __name__ == "__main__":
    # 入口函数通过asyncio.run()调用
    asyncio.run(main())

一般协程函数调用时在其前面加上await关键字进行调用：

'''
遇到问题没人解答？小编创建了一个Python学习交流QQ群：531509025
寻找有志同道合的小伙伴，互帮互助,群里还有不错的视频学习教程和PDF电子书！
'''
import asyncio
import time

async def say_after(delay, what):
    await asyncio.sleep(delay)
    print(what)

async def main():
    print(f"started at {time.strftime('%X')}")

    # 在前面加上await进行调用
    # 这种形式和正常的同步执行程序效果上没什么区别，仍是执行完上一步再执行下一步
    await say_after(1, 'hello')
    await say_after(2, 'world')

    print(f"finished at {time.strftime('%X')}")


if __name__ == "__main__":
    # 入口函数通过asyncio.run()调用
    asyncio.run(main())

最后一种是通过asyncio.create_task()调用一般协程函数。

第二种调用方式也是调用一般协程函数，但是如果只是这么调用的话协程函数并没有什么作用，比如上边这个函数耗时仍然和正常的同步版本一样是3秒。

协程的意义在正在于asyncio.create_task()调用形式，asyncio.create_task()可以将协程函数包装成任务，多个任务之间可并行执行。如下写法只耗时2秒。

import asyncio
import time

async def say_after(delay, what):
    await asyncio.sleep(delay)
    print(what)

async def main():
    print(f"started at {time.strftime('%X')}")

    task_list = []
    for i in range(2):
        # 步骤一、使用asyncio.create_task()调用协程函数，封装成任务
        tmp_task = asyncio.create_task(say_after(i, 'hello'))
        task_list.append(tmp_task)

    # 第二步，await任务
    for tmp_task in task_list:
        await tmp_task

    print(f"finished at {time.strftime('%X')}")

if __name__ == "__main__":
    asyncio.run(main())