ensure_future vs create_task

ensure_future это метод для создания Task С coroutine. Он создает задачи по-разному на основе аргумента (включая использование create_task для сопрограмм и будущее-как объекты).

create_task - это абстрактный метод AbstractEventLoop. Различные циклы событий могут реализовать эту функцию по-разному.

вы должны использовать ensure_future создать задачу. Вам понадобится create_task только если ты будешь чтобы реализовать свой собственный тип цикла событий.

Upd:

@bj0 указал на Гвидо по теме:

точки ensure_future() если у вас есть что-то, что может либо быть сопрограммой, либо Future (последнее включает в себя Task потому что это подкласс Future), и вы хотите иметь возможность вызывать метод на нем то, что определено только на Future (наверное, о единственном полезном пример cancel()). Когда это уже Future (или Task) это ничего не делает; когда это сопрограмма это обертывания его в Task.

если вы знаете, что у вас есть сопрограмма и вы хотите, чтобы это было запланировано, правильный API для использования create_task(). Единственный раз когда вы должны звоните ensure_future() это когда вы предоставляете API (как и большинство собственного API-интерфейсы ввода-вывода), которые можно либо сопрограмма или Future и вам нужно сделать что-то, что требует вы должны иметь Future.

и затем:

в конце концов я все еще верю, что ensure_future() соотвественно неясное имя для редко необходимой части функциональности. При создании задача из сопрограммы вы должны использовать соответствующее имя loop.create_task(). Может быть, для этого должен быть псевдоним asyncio.create_task()?

это удивительно для меня. Моя главная мотивация использовать ensure_future все это время было то, что это функция более высокого уровня по сравнению с членом цикла create_task (обсуждение содержит некоторые идеи, как добавить asyncio.spawn или asyncio.create_task).

я также могу указать, что, на мой взгляд, довольно удобно использовать универсальную функцию, которая может обрабатывать любые Awaitable а не только сопрограммы.

однако ответ Гвидо ясен: " при создании задачи из сопрограммы вы должны использовать соответствующее имя loop.create_task()"

когда сопрограммы должны быть обернуты в задачах?

обернуть сопрограмму в задачу-это способ запустить эту сопрограмму "в фоновом режиме". Вот пример:

import asyncio


async def msg(text):
    await asyncio.sleep(0.1)
    print(text)


async def long_operation():
    print('long_operation started')
    await asyncio.sleep(3)
    print('long_operation finished')


async def main():
    await msg('first')

    # Now you want to start long_operation, but you don't want to wait it finised:
    # long_operation should be started, but second msg should be printed immediately.
    # Create task to do so:
    task = asyncio.ensure_future(long_operation())

    await msg('second')

    # Now, when you want, you can await task finised:
    await task


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

выход:

first
long_operation started
second
long_operation finished

вы можете заменить asyncio.ensure_future(long_operation()) С await long_operation() чтобы почувствовать разницу.