如何提高Python asyncio事件循环警告的阈值时长？

你遇到的这个警告，是asyncio事件循环检测到某个回调/任务执行时间超过默认阈值（Python 3.11中默认是0.1秒）时触发的，和你的推测完全一致。以下是两种满足你需求的解决方案：

方案一：全局调整警告阈值 #

你可以直接修改事件循环的slow_callback_duration属性，将阈值提高到0.2秒，这样所有执行时间超过0.2秒的操作才会触发警告：

import asyncio

async def main():
    loop = asyncio.get_running_loop()
    # 设置慢回调警告阈值为0.2秒
    loop.slow_callback_duration = 0.2
    
    # 你的业务逻辑代码
    ...

asyncio.run(main())

这个设置是全局生效的，所有后续的asyncio回调/任务都会遵循这个新阈值。

方案二：针对特定操作临时禁用警告 #

如果你只想对预期耗时较长的操作（比如scipy.fft）屏蔽警告，而保留全局的阈值检测，可以临时修改阈值，操作完成后恢复原设置：

基础写法 #

import asyncio
from scipy.fft import fft

async def execute_fft(data):
    loop = asyncio.get_running_loop()
    # 保存原阈值
    original_threshold = loop.slow_callback_duration
    
    try:
        # 临时将阈值设为极大值，避免触发警告
        loop.slow_callback_duration = float('inf')
        # 执行耗时的FFT操作
        result = fft(data)
        return result
    finally:
        # 恢复原阈值
        loop.slow_callback_duration = original_threshold

复用性写法（上下文管理器） #

如果需要多次使用，可以封装成上下文管理器，更简洁：

import asyncio
from contextlib import contextmanager
from scipy.fft import fft

@contextmanager
def suppress_slow_callback_warnings(loop=None):
    if loop is None:
        loop = asyncio.get_running_loop()
    original_threshold = loop.slow_callback_duration
    try:
        loop.slow_callback_duration = float('inf')
        yield
    finally:
        loop.slow_callback_duration = original_threshold

# 使用示例
async def execute_fft(data):
    with suppress_slow_callback_warnings():
        result = fft(data)
    return result

额外优化建议 #

其实更符合asyncio异步模型的做法是，将耗时的同步操作（比如FFT）放到线程池里执行，避免阻塞事件循环，这样自然不会触发警告，同时还能保证其他异步任务正常运行：

import asyncio
from concurrent.futures import ThreadPoolExecutor
from scipy.fft import fft

async def execute_fft(data):
    loop = asyncio.get_running_loop()
    # 用线程池执行耗时操作，不阻塞事件循环
    result = await loop.run_in_executor(ThreadPoolExecutor(), fft, data)
    return result

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