与 aiohttp 服务器的并发

Question

这是我的代码：

import asyncio
import logging
import time

from aiohttp import web

logging.getLogger('aiohttp').setLevel(logging.DEBUG)
logging.getLogger('aiohttp').addHandler(logging.StreamHandler(sys.stderr))

def handle_sync(request):
    web.web_logger.debug('Sync begin')
    time.sleep(10)
    web.web_logger.debug('Sync end')
    return web.Response(text='Synchronous hello')


async def handle_async(request):
    web.web_logger.debug('Async begin')
    await asyncio.sleep(10)
    web.web_logger.debug('Async end')
    return web.Response(text='Asynchronous hello')


async def init(loop):
    app = web.Application(loop=loop)
    app.router.add_get('/sync/', handle_sync)
    app.router.add_get('/async/', handle_async)

    srv = await loop.create_server(app.make_handler(), '0.0.0.0', 8080)
    return srv

loop = asyncio.get_event_loop()
loop.run_until_complete(init(loop))
loop.run_forever()

我希望有两种行为：

• 当点击两次/sync/ url 时，假设间隔为 2 秒，总时间为 20 秒，因为我们在一个线程中有一个服务器，并且有一个阻塞调用
• 以相同方式点击两次/async/ url 的总时间为 12 秒（这些调用是异步的，对吗？）

但这两种情况似乎都持续了 20 秒，有人可以解释一下原因吗？

Answer 1

为了能够在此处观察使用异步的好处，您需要（几乎）同时发送两个单独的请求。

await 调用仅仅意味着函数将控制权交给事件循环，以便如果发生任何其他事件，它们可以在不阻塞的情况下进行处理。如果您确实同时向异步端点发送了两个请求，您会看到每个请求都在 10 秒左右完成。这是因为两个请求是同时处理的：第一个请求不会阻止服务器处理另一个请求。

但是，如果您以类似的方式向同步端点发送两个请求，则第二个请求将需要 20 秒。这是因为同步端点在第一个请求上阻塞并且在第一个请求完成之前无法开始为第二个请求提供服务。