nicejokerOwO 2021-11-10 14:03 采纳率: 100%
浏览 464
已结题

[Python]asyncio异步协程停止问题

python版本:3.9
做异步协程停止时,调用asyncio.Task.all_task时会报一个
AttributeError: type object '_asyncio.Task' has no attribute 'all_tasks'的错误
然后查了一下,说是3.9中把asyncio.Task.all_tasks移除了,用asyncio.all_tasks代替
代替后会报
RuntimeError: no running event loop的错误

以下是代码:

import time, asyncio


async def do_work(s):
    print('waiting:', s)
    await asyncio.sleep(s)
    return 'Done after {}s'.format(s)


# 创建协程对象
coroutine1 = do_work(1)
coroutine2 = do_work(2)
coroutine3 = do_work(4)

# 创建任务列表
tasks = [asyncio.ensure_future(coroutine1),
         asyncio.ensure_future(coroutine2),
         asyncio.ensure_future(coroutine3)]

start = time.time()
loop = asyncio.get_event_loop()
try:
    loop.run_until_complete(asyncio.wait(tasks))
except KeyboardInterrupt as e:
    # 获取事件循环中所有任务列表
    print(asyncio.all_tasks)
    for task in asyncio.all_tasks():
        print(task.cancel())    # 如果返回的True代表当前任务取消成功
    loop.stop()
    loop.run_forever()
finally:
    loop.close()
print('Time:', time.time()-start)

  • 写回答

3条回答 默认 最新

  • ~白+黑 Python领域新星创作者 2021-11-10 15:07
    关注

    RuntimeError: no running event loop的错误 没有在运行的事件循环 应该是这里的问题吧,loop = asyncio.get_event_loop()

    本回答被题主选为最佳回答 , 对您是否有帮助呢?
    评论
查看更多回答(2条)

报告相同问题?

问题事件

  • 系统已结题 11月19日
  • 已采纳回答 11月11日
  • 创建了问题 11月10日

悬赏问题

  • ¥20 西门子S7-Graph,S7-300,梯形图
  • ¥50 用易语言http 访问不了网页
  • ¥50 safari浏览器fetch提交数据后数据丢失问题
  • ¥15 matlab不知道怎么改,求解答!!
  • ¥15 永磁直线电机的电流环pi调不出来
  • ¥15 用stata实现聚类的代码
  • ¥15 请问paddlehub能支持移动端开发吗?在Android studio上该如何部署?
  • ¥20 docker里部署springboot项目,访问不到扬声器
  • ¥15 netty整合springboot之后自动重连失效
  • ¥15 悬赏!微信开发者工具报错,求帮改