问答

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

作者:admin 2021-04-19 我要评论

如下伪代码 import aiohttpimport asyncioasync def fetch(session, url): async with session.get(url, headers=headers) as resp: text = await resp.text() ...

在说正事之前,我要推荐一个福利:你还在原价购买阿里云、腾讯云、华为云服务器吗?那太亏啦!来这里,新购、升级、续费都打折,能够为您省60%的钱呢!2核4G企业级云服务器低至69元/年,点击进去看看吧>>>)

如下伪代码

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())

版权声明:本文转载自网络,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。本站转载出于传播更多优秀技术知识之目的,如有侵权请联系QQ/微信:153890879删除

相关文章
  • nginx响应速度很慢

    nginx响应速度很慢

  • 点击选中的多选框,会在已选那一栏显示

    点击选中的多选框,会在已选那一栏显示

  • PHP 多态的理解

    PHP 多态的理解

  • 关于C语言中static的问题

    关于C语言中static的问题

腾讯云代理商
海外云服务器