python asyncio 关闭task

• Z时代
• 2024-01-10
• 分类：综合

import asyncio
import time
async def get_html(sleep_times):
    print("waiting")
    await asyncio.sleep(sleep_times)
    print("done after {}s".format(sleep_times))
if __name__ == "__main__":
    task1 = get_html(2)
    task2 = get_html(3)
    task3 = get_html(3)
    tasks = [task1, task2, task3]
    loop = asyncio.get_event_loop()
    try:
        loop.run_until_complete(asyncio.wait(tasks))
    except KeyboardInterrupt as e:
        all_tasks = asyncio.Task.all_tasks()
        for task in all_tasks:
            print("cancel task")
            print(task.cancel())
        loop.stop() # 只是将stopping的标记置位true
        loop.run_forever() # 在stop后一定要运行这段代码，不然会抛异常
    finally:
        loop.close() # 里面更多的逻辑，真正的关闭

以上是 python asyncio 关闭task 的全部内容， 来源链接： utcz.com/z/389454.html