python - 如何创建一个返回值的异步任务？

Question

我正在研究如何在 asyncio 中返回一个列表[]
我知道 asyncio.gather可以帮助我，但有很多方法我现在很困惑。
我如何从 main() 返回值？谢谢

async def wait_until(dt):
    # sleep until the specified datetime
    now = datetime.now()
    await asyncio.sleep((dt - now).total_seconds())

async def run_at(dt, coro):
    await wait_until(dt)
    return await coro

async def main():
    test=[]
    async for message in client.iter_messages(channel):
        test.append(message)
        return test


loop = asyncio.get_event_loop()
loop.create_task(run_at(datetime(2020, 12, 29, 19, 17),main()))
loop.run_until_complete(asyncio.gather(*[main()]))
# How to get test[] or How to pass it to another task?
loop.run_forever()

Answer 1

来自 asyncio.gather 文档:

If all awaitables are completed successfully, the result is an aggregate list of returned values. The order of result values corresponds to the order of awaitables in aws.

来自 asyncio.loop.run_until_complete 文档:

Return the Future’s result or raise its exception.

所以 gather是 async def返回所有通过的结果，以及 run_until_complete运行循环将可等待对象“转换”为结果。基本上，返回值通过:

results = loop.run_until_complete(asyncio.gather(*[main()]))
tests = results[0]

请注意 gather只有一项是多余的，因为它相当于只使用一项:

tests = loop.run_until_complete(main())

如果你想在不使用全局变量的情况下交流两个独立的任务，你可能想使用 asyncio.Queue ，并为 async def 提供相同的队列实例作为输入参数。一会 put “消息”，另一个会 get 他们。
您可以将此与 wait 结合使用, gather , create_task等，几乎可以做你需要的一切。