Python asyncio：在没有创建任务的情况下启动循环

Question

有人可以解释一下，为什么我不能执行我的任务，如果我之前没有任何添加的任务启动循环？ （Python 3.7）

import asyncio
import threading    

def run_forever(loop):
    loop.run_forever()

async def f(x):
    print("%s executed" % x)

# init is called first
def init():
    print("init started")

    loop = asyncio.new_event_loop()

    # loop.create_task(f("a1")) # <--- first commented task

    thread = threading.Thread(target=run_forever, args=(loop,))
    thread.start()

    loop.create_task(f("a2")) # <--- this is not being executed

    print("init finished")

如果我对# loop.create_task(f("a1"))发表评论，执行是：

init started
init finished

未注释的执行是：

init started
init finished
a1 executed
a2 executed

为什么这样？我想创建一个循环并在将来添加任务。

Answer 1

除非另有明确说明，asyncio API is not thread-safe。这意味着从运行事件循环的线程以外的线程调用loop.create_task()将无法与循环正确同步。

要从外部线程向事件循环提交任务，您需要调用asyncio.run_coroutine_threadsafe：

asyncio.run_coroutine_threadsafe(f("a2"), loop)

这将唤醒循环以提醒它新任务已到达，并且它还返回一个concurrent.futures.Future，您可以使用它来获取协程的结果。