协程的一点问题

Question

代码如下，index函数处理到达的请求，init 初始化服务器，剩下的为创建服务器的代码

@asyncio.coroutine
def index(request):
    print('one connection come...')
    yield from asyncio.sleep(10)
    return web.Response(body=b'<h1>Awesome</h1>',content_type="text/html")

@asyncio.coroutine
def init(loop):
    app=web.Application(loop=loop)

    app.router.add_route('GET','/',index)

    
    srv=yield from  loop.create_server(app.make_handler(),'127.0.0.1',9000)
    logging.info('server start at ')
    return srv


loop=asyncio.get_event_loop()

loop.run_until_complete(init(loop))

loop.run_forever()

按照正常的思路，第一个请求到达后，index执行至 yield处，会重新回到时间循环，等待下一次循环，但是真正执行的时候 却一直把index执行完，才处理下一次请求。

Answer 1

这不是你的代码问题，是浏览器的连接机制造成困扰。

自己写一个客户端测试便知，如

# -*- coding: utf-8 -*-
import aiohttp
import asyncio


async def fetch(session, url):
    async with session.get(url) as response:
        return await response.text()


async def main():
    async with aiohttp.ClientSession() as session:
        htmls = await asyncio.gather(
            fetch(session, 'http://localhost:9000/'),
            fetch(session, 'http://localhost:9000/'),
        )
        print(htmls)


if __name__ == '__main__':
    loop = asyncio.get_event_loop()
    loop.run_until_complete(main())