如何在同步执行器中从异步FuncA调用并运行协程FuncB？

你的需求是可行的，分两种场景给出解决方案：

场景1：仅需让FuncB立即启动执行，无需等待结果 #

如果不需要在同步函数execute里获取FuncB的执行结果，只是希望它尽快被调度执行，同时让FuncA继续原有流程，直接用asyncio.create_task将FuncB加入当前事件循环的调度队列即可。

代码示例 #

import asyncio

async def funcB():
    print("FuncB 开始执行")
    # 模拟异步操作
    await asyncio.sleep(1)
    print("FuncB 执行完成")
    return "FuncB 的返回结果"

async def funcA():
    print("FuncA 启动")
    execute(funcB)
    print("FuncA 继续执行后续逻辑")
    # 模拟FuncA自身的异步操作
    await asyncio.sleep(2)
    print("FuncA 执行完成")

def execute(fn):
    # 将FuncB包装成任务，加入当前事件循环调度
    asyncio.create_task(fn())

asyncio.run(funcA())

执行逻辑：

• FuncA启动后调用execute，create_task会立即把FuncB加入事件循环的待执行队列
• FuncA无需等待，直接继续执行后续代码
• 事件循环在空闲时会立即调度执行FuncB，两者并行运行

场景2：需要在同步函数execute中等待FuncB完成并获取结果 #

由于当前线程的事件循环正在运行FuncA，直接调用loop.run_until_complete会导致死锁（事件循环被阻塞，无法继续调度任何任务，包括FuncA和FuncB）。此时需要通过新线程+独立事件循环的方式实现：

代码示例 #

import asyncio
import threading

async def funcB():
    print("FuncB 开始执行")
    await asyncio.sleep(1)
    print("FuncB 执行完成")
    return "FuncB 的返回结果"

async def funcA():
    print("FuncA 启动")
    result = execute(funcB)
    print(f"在FuncA中获取到FuncB的结果：{result}")
    print("FuncA 继续执行后续逻辑")
    await asyncio.sleep(2)
    print("FuncA 执行完成")

def execute(fn):
    task_result = None
    
    # 在新线程中创建独立事件循环并运行FuncB
    def run_in_isolated_loop():
        nonlocal task_result
        loop = asyncio.new_event_loop()
        asyncio.set_event_loop(loop)
        task_result = loop.run_until_complete(fn())
        loop.close()
    
    # 启动线程并等待其完成
    thread = threading.Thread(target=run_in_isolated_loop)
    thread.start()
    thread.join()
    
    return task_result

asyncio.run(funcA())

执行逻辑：

• execute启动新线程，在新线程内创建独立的事件循环来运行FuncB
• 主线程等待新线程完成，拿到FuncB的结果后返回给FuncA
• FuncA拿到结果后继续执行原有流程

你之前尝试失败的原因 #

1. loop.run_until_complete(task)：当前事件循环正在运行FuncA，调用该方法会阻塞主线程，导致事件循环无法调度任何任务，形成死锁，任务永远无法完成
2. while not task.done(): pass：忙等会占用CPU，但事件循环被主线程的忙等阻塞，无法调度FuncB执行，任务永远不会标记为完成
3. 线程中调用asyncio.create_task：create_task必须在有运行中事件循环的线程里调用，新线程默认没有事件循环，该操作无效；且你误用了x.run()（应调用x.start()），即使启动线程，也没有运行事件循环，FuncB不会被执行

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