您的位置:首页 > 脚本大全 > > 正文

协程在python中怎么使用(python协程之动态添加任务的方法)

更多 时间:2022-01-27 01:10:09 类别:脚本大全 浏览量:2543

协程在python中怎么使用

python协程之动态添加任务的方法

python协程只能运行在事件循环中,但是一旦事件循环运行,又会阻塞当前任务。所以只能在当前进程中再开一个线程,这个线程的主要任务是运行事件循环,就是event_loop,因为他是一个无限循环,会阻塞当前线程。

放一个自己写的demo,注释写的很详细。

另外还有一点需要注意,一个事件循环中不能运行另外一个事件循环。

运行结果:

协程在python中怎么使用(python协程之动态添加任务的方法)

  • ?
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
  • 28
  • 29
  • 30
  • 31
  • 32
  • 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协程之动态添加任务的方法就是小编分享给大家的全部内容了,希望能给大家一个参考,也希望大家多多支持开心学习网。

    原文链接:https://blog.csdn.net/qq_29349715/article/details/79730786

    标签:Python 协程 任务
    您可能感兴趣