立即运行任务然后等待

Question

我是 Python 新手，代码类似于以下内容：

import time
import asyncio

async def my_async_function(i):
    print("My function {}".format(i))

async def start():
    requests = []

    # Create multiple requests
    for i in range(5):
        print("Creating request #{}".format(i))
        requests.append(my_async_function(i))

    # Do some additional work here
    print("Begin sleep")
    time.sleep(10)
    print("End sleep")

    # Wait for all requests to finish
    return await asyncio.gather(*requests)

asyncio.run(start())

无论“额外工作”需要多长时间，请求似乎只在“结束睡眠”之后运行。我猜asyncio.gather 是真正开始执行它们的原因。我怎样才能让请求（又名my_async_function()）立即开始，做额外的工作，然后等待所有的最后完成？

编辑： 根据 Krumelur 的 cmets 和我自己的发现，我正在寻找以下结果：

import time
import asyncio
import random

async def my_async_function(i):
    print("Begin function {}".format(i))
    await asyncio.sleep(int(random.random() * 10))
    print("End function {}".format(i))

async def start():
    requests = []

    # Create multiple requests
    for i in range(10):
        print("Creating request #{}".format(i))
        requests.append(asyncio.create_task(my_async_function(i)))

    # Do some additional work here
    print("Begin sleep")
    await asyncio.sleep(5)
    print("End sleep")

    # Wait for all requests to finish
    return await asyncio.gather(*requests)

asyncio.run(start())

这仅在my_async_function 和“附加工作”都处于等待状态时才有效，以便事件循环可以给它们每个执行时间。你需要create_task（如果你知道它是协程）或ensure_future（如果它可能是协程或未来）来允许请求立即运行，否则它们仍然只有在你gather时才会运行。

Answer 1

time.sleep()是同步操作

你会想要使用异步睡眠并等待它， 例如

await asyncio.sleep(10)

其他异步代码只会在当前任务产生时运行（即通常在“等待”某事时）。

使用异步代码意味着您必须在任何地方继续使用异步。异步操作适用于 I/O-bound 应用程序。如果“额外工作”主要受 CPU 限制，则最好使用线程（但要注意全局解释器锁！）