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

协程在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 协程任务

上一篇：python实现简单加密（Python 隐藏输入密码时屏幕回显的实例）

下一篇：python能操作微信定时发消息（python给微信好友定时推送消息的示例）

您可能感兴趣

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

协程在python中怎么使用

热门推荐

排行榜