能否向运行协议服务器的asyncio循环加任务？为何示例代码无输出？

当然可以向运行中的asyncio事件循环添加任务，你的代码没打印Hello, world是因为直接把async函数传给call_soon_threadsafe没用——call_soon_threadsafe只会执行你传入的可调用对象，而hello()是个协程，光创建协程对象不会自动让事件循环调度它运行。

错误点拆解 #

原代码里的loop.call_soon_threadsafe(hello)，本质是让事件循环调用hello函数，得到一个协程对象，但事件循环不会主动去执行这个协程。你需要明确告诉事件循环：把这个协程包装成任务并调度运行。

两种修正方法 #

方法1：用asyncio.run_coroutine_threadsafe（推荐）

这是asyncio专门为跨线程提交协程设计的API，直接把协程对象传给它，它会自动在目标事件循环里创建任务并运行：

import asyncio
import threading
import time

class EchoProtocol(asyncio.Protocol):
    def connection_made(self, transport):
        self.transport = transport

    def data_received(self, data):
        self.transport.write(data)

loop = None
def serve():
    async def _serve():
        server = await asyncio.get_running_loop().create_server(EchoProtocol, '::1', 2000)
        await server.serve_forever()

    global loop
    loop = asyncio.new_event_loop()
    loop.run_until_complete(_serve())

async def hello():
    print("Hello, world", flush=True)

def main():
    t = threading.Thread(target=serve)
    t.start()
    time.sleep(0.1)
    # 替换原来的call_soon_threadsafe调用
    asyncio.run_coroutine_threadsafe(hello(), loop)
    t.join()

main()

方法2：通过call_soon_threadsafe调用loop.create_task

如果不想用专门的API，也可以在事件循环线程内调用loop.create_task来包装协程，这需要把创建任务的操作通过call_soon_threadsafe提交：

# main函数里的调用改成这样
loop.call_soon_threadsafe(lambda: loop.create_task(hello()))

或者封装成函数更清晰：

def submit_hello_task():
    loop.create_task(hello())

loop.call_soon_threadsafe(submit_hello_task)

核心要点 #

跨线程给asyncio事件循环加任务时，必须确保协程被包装成Task对象，事件循环才会调度它执行。run_coroutine_threadsafe帮你完成了这一步，而直接用call_soon_threadsafe需要手动在事件循环线程内调用create_task。

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