当前位置:首页 > Python教程 > python技巧

python asyncio 关闭task

            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() # 里面更多的逻辑,真正的关闭

 

原文:https://www.cnblogs.com/callyblog/p/11218228.html


【说明】本文章由站长整理发布,文章内容不代表本站观点,如文中有侵权行为,请与本站客服联系(QQ:254677821)!