asyncio.run()启动之后如何停止

  • Z时代
  • 2024-02-09
  • 分类：IT

asyncio.run()启动之后如何停止

如下伪代码

import aiohttp
import asyncio
async def fetch(session, url):
    async with session.get(url, headers=headers) as resp:
        text = await resp.text()
        这里判断拿到自己想要的东西了,
        该如何等当前还执行的task完成之后就停止，不再执行其他task呢
async def main():
        async with aiohttp.ClientSession(connector=tc) as session:
            tasks = []
            for url in url_list:
                task = fetch(session, url)
                tasks.apped(task)
            await asyncio.wait(tasks)
if __name__ == '__main__':
    asyncio.run(main())

回答：

看代码这是一个web服务吧，def fetch异步处理请求，在得到想要的请求后就不处理了？？那不就是请求告诉服务你该退出了？ 那可以sys.exit() 你这样很奇葩

以上是 asyncio.run()启动之后如何停止 的全部内容， 来源链接： utcz.com/p/937942.html

回到顶部