如何将异步函数传入run_in_executor？解决协程未被await警告

1. 能不能把异步函数传入run_in_executor？ #

不行。run_in_executor的设计目的是执行同步函数，它不会处理协程对象。当你把异步函数传给它时，函数会被调用并返回一个协程对象，但executor不会自动await这个协程，所以会触发"coroutine was never awaited"的警告，且你的异步逻辑根本不会真正执行。

如果非要在executor里跑异步函数，需要用同步函数包装，手动创建事件循环运行协程，比如：

def wrap_async_func(num):
    return asyncio.run(some_async_func(num))

# 之后在run_in_executor中传入这个包装函数
result = await loop.run_in_executor(None, wrap_async_func, 1)

但这种做法没必要——异步函数本身就该在事件循环里运行，套线程反而浪费资源，除非你的异步函数里混了阻塞代码，那时候应该把阻塞部分单独丢去executor，而非整个异步函数。

2. 实现Y个线程运行X个异步协程 #

核心思路：每个线程创建独立的事件循环，在每个循环里运行指定数量的协程。下面是具体示例（以3个线程运行10个协程为例）：

import asyncio
import random
from threading import Thread, get_ident

async def some_async_func(num):
    ident = get_ident()
    print(f"produce: {num} in thread {ident}", flush=True)
    await asyncio.sleep(random.uniform(0, 0.5))
    return {ident: num}

# 单个线程执行指定协程集合的逻辑
def run_coroutines_in_thread(coroutine_list):
    loop = asyncio.new_event_loop()
    asyncio.set_event_loop(loop)
    # 批量运行协程并收集结果
    results = loop.run_until_complete(asyncio.gather(*coroutine_list))
    loop.close()
    return results

def main():
    total_coroutines = 10  # X个异步协程
    total_threads = 3      # Y个线程

    # 生成所有待执行的协程
    all_coros = [some_async_func(i) for i in range(total_coroutines)]
    # 把协程分成Y组，处理余数避免遗漏
    group_size = total_coroutines // total_threads
    coro_groups = [all_coros[i*group_size : (i+1)*group_size] for i in range(total_threads-1)]
    coro_groups.append(all_coros[(total_threads-1)*group_size:])

    # 启动线程执行各组协程
    threads = []
    all_results = []
    for group in coro_groups:
        # 用lambda传递参数，确保每组协程对应一个线程
        t = Thread(target=lambda g: all_results.extend(run_coroutines_in_thread(g)), args=(group,))
        threads.append(t)
        t.start()

    # 等待所有线程执行完毕
    for t in threads:
        t.join()

    print("所有任务完成，结果汇总：")
    for res in all_results:
        print(res)

if __name__ == "__main__":
    main()

代码说明： #

• run_coroutines_in_thread：每个线程的入口逻辑，创建独立事件循环，运行传入的协程列表并返回结果。
• main函数：先生成全部协程，再按线程数分组，最后启动线程并行执行各组任务，等待所有线程结束后输出汇总结果。

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