Asyncio не работает параллельно

Я запускаю этот пример asyncio

import asyncio
from aiohttp import ClientSession

async def fetch(url, session, index):
    async with session.get(url) as response:
        print("Before " + str(index))
        buffer = await response.read()
        print("After " + str(index))

async def run(r):
    url = "http://google.com"
    tasks = []

    # Fetch all responses within one Client session,
    # keep connection alive for all requests.
    async with ClientSession() as session:
        for i in range(r):
            task = asyncio.ensure_future(fetch(url, session, i))
            tasks.append(task)

        responses = await asyncio.gather(*tasks)
        # you now have all response bodies in this variable
        print(responses)

def print_responses(result):
    print(result)

loop = asyncio.get_event_loop()
future = asyncio.ensure_future(run(4))
loop.run_until_complete(future)

Результаты примерно такие

Before 1
After 1
Before 3
After 3
Before 2
After 2
Before 0
After 0

Похоже, что вещи работают серийно. Сама часть выборки занимает несколько миллисекунд. Я запускал его несколько раз, но результаты не совпадают. Какие-либо предложения?

Попробуйте переместить print("Before") до session.get(). Если тело ответа прибывает в том же пакете, что и заголовки, response.read() не будет блокироваться и, следовательно, не будет причин для приостановки сопрограммы. Это дает вам видимость того, что все работает последовательно, хотя на самом деле параллелизм имел место во время get().

user4815162342 23.04.2018 17:50
Почему в Python есть оператор "pass"?
Почему в Python есть оператор "pass"?
Оператор pass в Python - это простая концепция, которую могут быстро освоить даже новички без опыта программирования.
Некоторые методы, о которых вы не знали, что они существуют в Python
Некоторые методы, о которых вы не знали, что они существуют в Python
Python - самый известный и самый простой в изучении язык в наши дни. Имея широкий спектр применения в области машинного обучения, Data Science,...
Основы Python Часть I
Основы Python Часть I
Вы когда-нибудь задумывались, почему в программах на Python вы видите приведенный ниже код?
LeetCode - 1579. Удаление максимального числа ребер для сохранения полной проходимости графа
LeetCode - 1579. Удаление максимального числа ребер для сохранения полной проходимости графа
Алиса и Боб имеют неориентированный граф из n узлов и трех типов ребер:
Оптимизация кода с помощью тернарного оператора Python
Оптимизация кода с помощью тернарного оператора Python
И последнее, что мы хотели бы показать вам, прежде чем двигаться дальше, это
Советы по эффективной веб-разработке с помощью Python
Советы по эффективной веб-разработке с помощью Python
Как веб-разработчик, Python может стать мощным инструментом для создания эффективных и масштабируемых веб-приложений.
1
1
1 165
1

Ответы 1

Как упоминалось в комментариях, вполне вероятно, что к моменту вызова response.read() больше нечего загружать, сопрограмма не приостанавливается, а затем немедленно вызывается print("After " + str(index)).

Чтобы увидеть больше смешения, вы можете выбрать более медленный URL. Например для меня

url = "http://speedtest.tele2.net/100MB.zip"

выходы

Before 0
Before 1
Before 3
Before 2
After 0
After 1
After 2
After 3

Другие вопросы по теме