跨不同事件循环调用asyncio.run_coroutine_threadsafe是否线程安全？

核心结论 #

asyncio.run_coroutine_threadsafe本身是线程安全的——不管调用方所在线程是否拥有独立事件循环，只要目标事件循环是合法且运行中的，跨不同事件循环的线程调用它提交协程，都不会破坏其线程安全性。该API的设计初衷就是支持跨线程向指定事件循环提交任务，内部已经通过线程安全的机制（如队列+锁）实现了跨线程的协程调度。

需要注意的额外风险与修正点 #

• 共享状态的并发安全：你的代码中self.state被主线程事件循环的regular_func和子线程事件循环的flush_state同时访问/修改，这部分未加锁保护，会引发并发修改的异常或数据不一致问题。需用threading.Lock（跨线程场景下优先）包裹对self.state的读写操作。
• 静态方法定义错误：B类的process_inputs标注为@staticmethod，但参数列表写了self，会导致调用时参数不匹配。正确写法应为：

  class B:
      @staticmethod
      async def process_inputs(inputs):
          # 处理逻辑（上传对象存储、调用外部API等）
  

• 子线程事件循环的优雅退出：当前flush_state是无限循环，服务关闭时子线程会无法正常终止。建议增加一个停止标志（如self._stop_flush = False），在服务shutdown时设置标志并退出循环，同时关闭子线程的事件循环。

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