"""Когда начинается тело корутины и когда `await` действительно уступает ход.

ЗАЧЕМ ЭТОТ ФАЙЛ. Короткий ответ урока говорил: «выполнение начинается только
там, где этот объект ждут, и там же работа уступает управление другим».
Аудит 01.11.2026 (Q-02) возразил двумя контрпримерами:

  1. `asyncio.create_task(coro())` планирует корутину, и её тело может
     исполниться до любого `await task` — достаточно, чтобы текущая задача
     приостановилась на чём-то другом;
  2. `await` уже завершившегося Future (или корутины, которая сама ни разу не
     приостановилась) не обязан передавать ход другой задаче.

Оба утверждения здесь проверяются прогоном, а не пересказом документации.

ПОЧЕМУ ЖУРНАЛ СОБЫТИЙ, А НЕ ЗАМЕР ВРЕМЕНИ. Вопрос — порядок событий, а не
стоимость. Каждая корутина пишет строку в общий список; печатается он целиком.
От тулчейна вывод не зависит.

ЗАПУСК: python3.14 bench/async-await/when_it_runs.py
Вывод по версиям: runs/when_it_runs-3.14.txt и соседние.
"""

import asyncio
import sys

LOG: list[str] = []


def show(title: str) -> None:
    print()
    print(title)
    print("-" * len(title))


def dump() -> None:
    for line in LOG:
        print(f"  {line}")
    LOG.clear()


async def body(name: str) -> str:
    LOG.append(f"{name}: тело началось")
    return name


async def neighbour() -> None:
    LOG.append("сосед: получил ход")


async def no_suspend() -> int:
    # Корутина без единой точки приостановки: await такой корутины
    # выполняет её до конца, не возвращаясь в цикл событий.
    return 42


# ---------------------------------------------------------------------------
# 1. Тело задачи исполняется до `await task`
# ---------------------------------------------------------------------------

async def task_before_await() -> None:
    task = asyncio.create_task(body("задача"))
    LOG.append(f"сразу после create_task: тело началось = {'задача: тело началось' in LOG}")
    await asyncio.sleep(0)  # приостановка на ДРУГОМ ожидании, не на task
    LOG.append(f"после await asyncio.sleep(0): task.done() = {task.done()}")
    LOG.append("теперь await task")
    result = await task
    LOG.append(f"await task вернул {result!r}")


# ---------------------------------------------------------------------------
# 2. С eager_task_factory (3.12+) тело идёт прямо внутри create_task
# ---------------------------------------------------------------------------

async def eager() -> None:
    loop = asyncio.get_running_loop()
    loop.set_task_factory(asyncio.eager_task_factory)
    LOG.append("перед create_task")
    task = asyncio.create_task(body("eager-задача"))
    LOG.append(f"сразу после create_task: task.done() = {task.done()}")
    await task
    loop.set_task_factory(None)


# ---------------------------------------------------------------------------
# 3. await завершившегося Future не даёт хода соседу
# ---------------------------------------------------------------------------

async def done_future() -> None:
    loop = asyncio.get_running_loop()
    fut = loop.create_future()
    fut.set_result("готово")
    asyncio.create_task(neighbour())  # сосед готов к запуску
    value = await fut
    LOG.append(f"await завершившегося Future вернул {value!r}; сосед ходил = {'сосед: получил ход' in LOG}")
    value = await no_suspend()
    LOG.append(f"await корутины без приостановки вернул {value}; сосед ходил = {'сосед: получил ход' in LOG}")
    await asyncio.sleep(0)
    LOG.append(f"после await asyncio.sleep(0): сосед ходил = {'сосед: получил ход' in LOG}")


# ---------------------------------------------------------------------------
# 4. Корутину исполняет asyncio.run — без единого await над её объектом
# ---------------------------------------------------------------------------

async def top() -> str:
    LOG.append("top: тело началось")
    return "top готов"


def main() -> None:
    print(f"Python {sys.version.split()[0]} ({sys.implementation.name})")

    show("1. ТЕЛО ЗАДАЧИ ИСПОЛНЯЕТСЯ ДО AWAIT TASK")
    asyncio.run(task_before_await())
    dump()

    show("2. С EAGER-ФАБРИКОЙ ЗАДАЧ ТЕЛО ИДЁТ ВНУТРИ CREATE TASK")
    if hasattr(asyncio, "eager_task_factory"):
        asyncio.run(eager())
        dump()
    else:
        print("  eager_task_factory нет в этой версии (появилась в 3.12)")

    show("3. AWAIT ГОТОВОГО РЕЗУЛЬТАТА НЕ УСТУПАЕТ ХОД")
    asyncio.run(done_future())
    dump()

    show("4. КОРУТИНУ ИСПОЛНЯЕТ ASYNCIO.RUN")
    result = asyncio.run(top())
    LOG.append(f"asyncio.run вернул {result!r}")
    dump()


if __name__ == "__main__":
    main()