python中的asyncio异步协程怎么实现

这篇"python中的asyncio异步协程怎么实现"文章的知识点大部分人都不太理解，所以小编给大家总结了以下内容，内容详细，步骤清晰，具有一定的借鉴价值，希望大家阅读完这篇文章能有所收获，下面我们一起来看看这篇"python中的asyncio异步协程怎么实现"文章吧。

一、定义协程

• asyncio 执行的任务，称为协程，但是Asyncio 并不能带来真正的并行

• Python 的多线程因为 GIL（全局解释器锁）的存在，也不能带来真正的并行

import asyncio# 通过 async 定义一个协程async def task():print('这是一个协程')# 判断是否是一个协程，返回Trueprint(asyncio.iscoroutinefunction(task))

二、运行协程

import asyncio# 通过 async 定义一个协程async def task(s):print('请等待 {} 秒'.format(s))await asyncio.sleep(s)print('协程结束')# 协程运行loop = asyncio.get_event_loop()loop.run_until_complete(task(3))

三、协程回调

• 加入我们处理完协程任务后，需要告诉开发人员，这里程序结束了

• 就需要使用到协程回调

import asyncio# 通过 async 定义一个协程async def task(s):print('请等待 {} 秒'.format(s))await asyncio.sleep(s)return '这里task结束了，其他的继续吧'def callback(future):print(future.result())future = asyncio.ensure_future(task(3))future.add_done_callback(callback)loop = asyncio.get_event_loop()loop.run_until_complete(future)# 结果如下：# 请等待 3 秒# 这里task结束了，其他的继续吧

四、运行多个协程

• 常常同一个项目中有多个协程

• 需要借助 asyncio.gather 函数运行

import asyncio# 通过 async 定义一个协程async def task1(s):print('请等待 {} 秒'.format(s))await asyncio.sleep(s)print('这里task1结束了')# 通过 async 定义一个协程async def task2(s):print('请等待 {} 秒'.format(s))await asyncio.sleep(s)print('这里task2结束了')# 运行方法一loop = asyncio.get_event_loop()loop.run_until_complete(asyncio.gather(task1(1), task2(3)))# 运行方法二coros = [task1(1), task1(3)]loop.run_until_complete(asyncio.gather(*coros))# 结果如下：# 请等待 1 秒# 请等待 3 秒# 这里task1结束了# 这里task2结束了

五、run_forever

• 通过run_until_complete 运行协程，协程运行完，程序也就结束退出了

• 使用run_forever 运行，程序并不会退出，除非调用 loop.stop()

import asyncio# 通过 async 定义一个协程async def task(s):await asyncio.sleep(s)# 程序并未退出结束loop = asyncio.get_event_loop()asyncio.ensure_future(task(3))loop.run_forever()

• 如果想让其退出，需要调用 loop.stop()

• 我们可以在协程中调用

import asyncio# 通过 async 定义一个协程async def task(loop, s):await asyncio.sleep(s)# 关闭run_foreverloop.close()loop = asyncio.get_event_loop()asyncio.ensure_future(task(loop, 3))loop.run_forever()

六、多协程中关闭run_forever

• 单个协程中可以通过在协程中关闭，但是如果是两个以上的协程的时候

• 如果有一个协程先做完了就stop了，将会导致其他的协程也会异常退出，这肯定是不允许的

• 所以我们可以在回调函数中进行关闭

import asyncio, functoolsasync def task(x):await asyncio.sleep(x)print('这是协程任务')def callback(loop):loop.stop()loop = asyncio.get_event_loop()future = asyncio.gather(task(1), task(3))future.add_done_callback(functools.partial(callback, loop))loop.run_forever()

以上就是关于"python中的asyncio异步协程怎么实现"这篇文章的内容，相信大家都有了一定的了解，希望小编分享的内容对大家有帮助，若想了解更多相关的知识内容，请关注行业资讯频道。