asyncio的gather和aiohttp ——》收集http响应实例_asyncio.gather http

# coding=utf-8
import time
import asyncio
from aiohttp import ClientSession


async def hello (url):
    async with ClientSession() as session:
        async with session.get(url) as response:
            print('Hello World:%s' % time.ctime())
            return await response.read()


async def main (loop):
    now = time.time()
    tasks = []
    urls = [
        "https://docs.python.org/3/library/asyncio-task.html",
        "https://www.cnblogs.com/yzh2857/p/10376598.html",
        "https://www.cnblogs.com/yzh2857/p/10390808.html",
        "https://matplotlib.org/api/pyplot_api.html",
        "https://www.programcreek.com/python/index/module/list",
    ]
    for url in urls:
        task = asyncio.ensure_future(hello(url))
        tasks.append(task)
    result = await asyncio.gather(*tasks)
    print("结果：", result)
    print("总用时", time.time() - now)


if __name__ == '__main__':
    loop = asyncio.get_event_loop()
    # ---------------------------------------------
    try:
        loop.run_until_complete(main(loop))
    finally:
        loop.close()


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40

输出：

Hello World:Wed Oct  9 13:35:47 2019
Hello World:Wed Oct  9 13:35:47 2019
Hello World:Wed Oct  9 13:35:48 2019
Hello World:Wed Oct  9 13:35:48 2019
Hello World:Wed Oct  9 13:35:48 2019
结果：......
总用时 2.0188119411468506
1
2
3
4
5
6
7