主页 / user-518790

Иван's questions

Martin Hope
Иван
Asked: 2024-11-27 22:28:41 +0000 UTC
  • 7

请告诉新手 asyncio 中的 wait 工作原理的细微差别。示例代码。

import asyncio

async def some_task():
    print("Задача начата")
    await asyncio.sleep(2)
    print("Задача завершена")

async def main():

    task = asyncio.create_task(some_task())
    #await asyncio.sleep(5)
    await task
    #await asyncio.sleep(5)


asyncio.run(main())
  1. 如果我只是运行await task，一切都清楚了，任务在2秒内运行
  2. 如果我在await任务之前设置await asyncio.sleep(5)，那么程序的总执行时间是5秒，程序内部的任务是2秒
  3. 如果我在await任务之后设置await asyncio.sleep(5)，那么程序的总执行时间约为7秒，程序内部的任务为2秒

为什么在一种情况下两个任务“并行”执行，而在另一种情况下“顺序”执行？提前致谢。

python
Martin Hope
Иван
Asked: 2024-11-26 22:11:52 +0000 UTC
  • 5

我正在学习 asyncio 并需要解决以下问题。如果协程完成时间超过 3 秒，则需要完成任务。其余任务必须在10秒后完成（程序总运行时间为10秒）。像这样的代码。

async def some_coro(time):
    print(f"Корутина {asyncio.current_task().get_name()} запустилась")
    try:
       await asyncio.sleep(time)
       print(f"Корутина {asyncio.current_task().get_name()} завершилась")
    except asyncio.CancelledError:
       print(f"Корутина {asyncio.current_task().get_name()} отменена")
    

async def wait_10():
    print('начало отсчета 10 сек')
    await asyncio.sleep(10)
    print ('10 сек прошло. Завершаем все задачи')
    for task in asyncio.all_tasks():
        try:
            task.cancel()
        except asyncio.CancelledError:
            pass

async def main():
   tasks = [asyncio.create_task(some_coro(12)), asyncio.create_task(some_coro(2)), asyncio.create_task(some_coro(15))]
    #await asyncio.create_task(wait_10())
   await asyncio.wait(tasks, timeout=5)

asyncio.run(main())

如果我只运行一个 asyncio.wait(tasks, timeout=5)。然后简单地在 5 秒后取消未完成的任务（但没有 10 秒的通用计数器）如果我添加等待 asyncio.create_task(wait_10())，那么似乎 asyncio.wait 中的超时“不再起作用”，并且这对我来说就是全部任务在 10 秒后完成，而不是在 5 秒超时后完成。首先，我想亲自了解为什么会发生这种情况？其次，是否可以制作“两个独立”的计数器？我觉得我缺少一些异步基础知识，想弄清楚。提前致谢。

python