如何在未知可等待对象数量时调度其顺序执行且无需await？

我想实现的核心功能是按顺序调度可等待对象执行，但不需要立即await它们，且不确定要执行的可等待对象数量。

用线程实现的代码如下：

def foo():
   # 一些阻塞调用 

result_list = []
threads = []
for i in events:  # events是每次都不同的列表
     newthread = threading.Thread(target=foo, args=())          
     threads.append(newthread)
     newthread.start()
print(result_list)

我尝试把这段代码转成异步代码，认为foo()应该写成这样：

async def foo():
   global result_list
   result = await blocking_call()
   result_list.append(result)

但试过在另一个线程中创建任务，方法似乎没法正常工作。

补充说明
我实际要实现的逻辑类似这样：

def foo():
   # 一些阻塞调用 

result_list = []
threads = []
for i in events:  # events是每次都不同的列表
     time.sleep(i)
     newthread = threading.Thread(target=foo, args=())          
     threads.append(newthread)
     newthread.start()
print(result_list)

直接基于异步事件循环动态创建任务即可，无需额外线程，以下是完整实现：

完整异步代码 #

import asyncio

async def foo(result_list):
    # 用asyncio.to_thread包装阻塞调用，避免阻塞事件循环
    result = await asyncio.to_thread(blocking_call)
    result_list.append(result)

async def main(events):
    result_list = []
    tasks = []
    for i in events:
        # 替换原代码的time.sleep，用异步睡眠不阻塞事件循环
        await asyncio.sleep(i)
        # 动态创建任务，加入事件循环调度
        task = asyncio.create_task(foo(result_list))
        tasks.append(task)
    # 等待所有任务执行完毕，确保结果全部收集
    await asyncio.gather(*tasks)
    print(result_list)

# 启动异步程序
if __name__ == "__main__":
    # 替换为你的实际events列表
    events = [1, 2, 0.5]
    asyncio.run(main(events))

关键细节说明 #

• 不用全局变量：把result_list作为参数传入foo，比全局变量更安全，符合异步编程规范。
• 处理阻塞函数：asyncio.to_thread()会把阻塞的blocking_call放到线程池执行，不会卡住异步事件循环。
• 动态任务调度：循环中用asyncio.create_task()创建任务，自动加入事件循环，不管任务数量多少都能处理。
• 等待任务结束：asyncio.gather()会等待所有任务完成，保证打印result_list时所有结果都已写入。
• 异步睡眠：asyncio.sleep(i)替代time.sleep(i)，不会阻塞整个事件循环，其他已创建的任务可以正常运行。

之前方法失效的原因 #

如果之前跨线程创建异步任务，是因为异步任务必须在同一个事件循环上下文中运行，跨线程操作需要特殊处理，但这个场景完全没必要多线程，直接在异步事件循环内动态创建任务即可。

内容的提问来源于stack exchange，提问作者markiZZ