简单讲一下 asyncio 的run_coroutine_threadsafe

啥是 runcoroutinethreadsafe？

想象你在一个多线程程序里跑着，主线程用 threading 干活，但你还想偷偷塞点异步任务（asyncio 的协程）进去。问题来了：asyncio 的东西得在事件循环里跑，而线程和事件循环不是一个世界，怎么办？runcoroutinethreadsafe 就是个“跨界送信员”，帮你从线程里安全地把协程扔到 asyncio 的事件循环里去执行。

简单说：它是从线程里调用异步代码的桥梁。

怎么用？ 基本用法 你得先有个跑着的事件循环，然后从线程里用这个函数提交任务。

import asyncio
import threading
import time

# 异步任务
async def say_hello():
    print("Hello from asyncio")
    await asyncio.sleep(1)
    print("Goodbye from asyncio")

# 线程里跑的函数
def thread_task(loop):
    print("线程开始干活")
    # 从线程提交协程到事件循环
    future = asyncio.run_coroutine_threadsafe(say_hello(), loop)
    # 等结果（可选）
    result = future.result()  # 阻塞等协程跑完
    print("线程拿到结果:", result)

# 主函数：启动事件循环
def main():
    loop = asyncio.get_event_loop()
    # 在线程里跑
    t = threading.Thread(target=thread_task, args=(loop,))
    t.start()
    # 主线程跑事件循环
    loop.run_forever()
    t.join()

if __name__ == "__main__":
    main()

输出：

线程开始干活
Hello from asyncio
(等1秒)
Goodbye from asyncio
线程拿到结果: None

关键点 1 asyncio.runcoroutinethreadsafe(协程, 事件循环)：

• 第一个参数是你的异步函数（协程）。
• 第二个参数是目标事件循环（得是已经跑起来的）。

返回一个 concurrent.futures.Future 对象，可以用 .result() 拿结果。

2 事件循环得活着：

• loop.run_forever() 让事件循环一直跑，不然协程没机会执行。
• 如果用 asyncio.run()，它会自动关循环，不适合这种场景。

3 线程安全：

这个函数专门设计来避免线程和 asyncio 的冲突，直接扔任务不用操心。

啥时候用？

你有个多线程程序，但某些任务想用 asyncio 的异步库（比如 aiohttp 发请求）。

主程序跑线程，但想“借用”事件循环跑点异步活儿。

比如：线程下载文件，异步上传结果。

import asyncio
import threading
import time

async def async_task():
    await asyncio.sleep(1)
    return "异步任务完成"

def thread_worker(loop):
    print("线程喊：干点异步活儿")
    future = asyncio.run_coroutine_threadsafe(async_task(), loop)
    result = future.result()
    print("线程收到:", result)

loop = asyncio.new_event_loop()
t = threading.Thread(target=thread_worker, args=(loop,))
t.start()

# 主线程跑循环
asyncio.set_event_loop(loop)
loop.run_forever()

输出：

线程喊：干点异步活儿
(等1秒)
线程收到: 异步任务完成

就是个“跨界工具”，让线程和 asyncio 和平共处。