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 技术交流群。
绑定邮箱获取回复消息
由于您还没有绑定你的真实邮箱,如果其他用户或者作者回复了您的评论,将不能在第一时间通知您!
发布评论
评论(1)
看代码这是一个web服务吧,def fetch异步处理请求,在得到想要的请求后就不处理了??那不就是请求告诉服务你该退出了? 那可以sys.exit() 你这样很奇葩