Python的asyncio接口loop.create_task(...)是否是线程安全的？

直接调用会产生异常 #

asyncio事件循环的绝大多数API都不是线程安全的，loop.create_task()就属于非线程安全接口，只能在事件循环所属的线程内调用。你在主线程中直接对另一个线程运行的事件循环调用该方法，会触发竞态条件，可能出现任务丢失、调度逻辑异常，严重时会直接导致事件循环崩溃，在你当前主线程运行matplotlib、事件循环线程并行处理UDP数据的场景下，异常出现的概率会更高。

正确的实现方式 #

• 你需要使用asyncio专门提供的跨线程操作接口loop.call_soon_threadsafe()来提交创建任务的操作，该接口会保证提交的操作在事件循环所属线程内安全执行，示例写法如下：

# 主线程中执行，listener_coroutine为你的监听器协程对象
loop.call_soon_threadsafe(loop.create_task, listener_coroutine)

• 额外注意事项：matplotlib的所有绘图、GUI相关操作都必须在主线程执行，不要在事件循环的协程内直接操作matplotlib接口。你可以用线程安全的queue.Queue作为数据中转层：事件循环线程将收到的各数据源UDP数据写入队列，主线程通过matplotlib内置的定时器定期从队列拉取数据更新绘图，避免出现界面无响应、绘图崩溃的问题。

内容的提问来源于stack exchange，提问作者Aaron de Windt