portaltest.py

from concurrent.futures import as_completed

from anyio import start_blocking_portal, sleep


async def long_running_task(index):
    await sleep(1)
    print(f'Task {index} running...')
    await sleep(index)
    return f'Task {index} return value'


with start_blocking_portal() as portal:
    futures = [portal.spawn_task(long_running_task, i) for i in range(1, 5)]
    for future in as_completed(futures):
        print(future.result())