python协程之动态添加任务的方法
更新时间：2019年02月19日 14:16:30 作者：梦醒人醉
今天小编就为大家分享一篇python协程之动态添加任务的方法，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧
python协程只能运行在事件循环中，但是一旦事件循环运行，又会阻塞当前任务。所以只能在当前进程中再开一个线程，这个线程的主要任务是运行事件循环，就是event_loop,因为他是一个无限循环，会阻塞当前线程。
放一个自己写的demo，注释写的很详细。
另外还有一点需要注意，一个事件循环中不能运行另外一个事件循环。
运行结果：
import asyncio
from threading import Thread
async def production_task():
i = 0
while True:
# 将consumption这个协程每秒注册一个到运行在线程中的循环，thread_loop每秒会获得一个一直打印i的无限循环任务
asyncio.run_coroutine_threadsafe(consumption(i),
thread_loop) # 注意：run_coroutine_threadsafe 这个方法只能用在运行在线程中的循环事件使用
await asyncio.sleep(1) # 必须加await
i += 1
async def consumption(i):
while True:
print("我是第{}任务".format(i))
await asyncio.sleep(1)
def start_loop(loop):
# 运行事件循环， loop以参数的形式传递进来运行
asyncio.set_event_loop(loop)
loop.run_forever()
thread_loop = asyncio.new_event_loop() # 获取一个事件循环
run_loop_thread = Thread(target=start_loop, args=(thread_loop,)) # 将次事件循环运行在一个线程中，防止阻塞当前主线程
run_loop_thread.start() # 运行线程，同时协程事件循环也会运行
advocate_loop = asyncio.get_event_loop() # 将生产任务的协程注册到这个循环中
advocate_loop.run_until_complete(production_task()) # 运行次循环
以上这篇python协程之动态添加任务的方法就是小编分享给大家的全部内容了，希望能给大家一个参考，也希望大家多多支持脚本之家。
相关文章
这篇文章主要介绍了python将ansible配置转为json格式实例代码的相关资料,需要的朋友可以参考下2017-05-05
python elasticsearch从创建索引到写入数据的全过程
这篇文章主要介绍了python elasticsearch从创建索引到写入数据的方法，本文通过实例代码给大家介绍的非常详细，具有一定的参考借鉴价值,需要的朋友可以参考下2019-08-08
这篇文章主要为大家详细介绍了Pandas时序数据，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下，希望能够给你带来帮助2022-03-03
reduce函数原本在python2中也是个内置函数，不过在python3中被移到functools模块中，这篇文章主要介绍了Python reduce()函数的用法,需要的朋友可以参考下2023-05-05
本篇文章主要介绍了Python实现数据库并行读取和写入实例，非常具有实用价值，需要的朋友可以参考下2017-06-06
这篇文章主要介绍了用python查找统一局域网下ip对应的mac地址的示例代码，帮助大家更好的理解和使用python，感兴趣的朋友可以了解下2021-01-01
这篇文章主要介绍了Python sys.argv用法实例,sys.argv[]是用来获取命令行参数的,sys.argv[0]表示代码本身文件路径,其它则用来表示获取输入参数,需要的朋友可以参考下2015-05-05
AI生成图片Stable Diffusion环境搭建与运行方法
Stable Diffusion是一种基于扩散过程的生成模型，由Ge et al.在2021年提出，该模型利用了随机变量的稳定分布，通过递归地应用扩散过程来生成高质量的图像，这篇文章主要介绍了AI图片生成Stable Diffusion环境搭建与运行,需要的朋友可以参考下2023-05-05
这篇文章主要介绍了基于python代码批量处理图片resize，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧2020-06-06
tensorflow的ckpt及pb模型持久化方式及转化详解
今天小编就为大家分享一篇tensorflow的ckpt及pb模型持久化方式及转化详解，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧2020-02-02
最新评论