Function run_blocking

runtime/python/websocket/funasr_wss_server.py:306–316

把阻塞函数丢线程池执行，避免卡 event loop。 sem 用于限流（避免 GPU / 模型被打爆）。

(fn, *a, sem: asyncio.Semaphore | None = None, **kw)

async def run_blocking(fn, *a, sem: asyncio.Semaphore | None = None, **kw):
    """
    把阻塞函数丢线程池执行，避免卡 event loop。
    sem 用于限流（避免 GPU / 模型被打爆）。
    """
    loop = asyncio.get_running_loop()
    call = functools.partial(fn, *a, **kw)
    if sem is None:
        return await loop.run_in_executor(EXECUTOR, call)
    async with sem:
        return await loop.run_in_executor(EXECUTOR, call)


def _generate_sync(model, audio_or_text, status_dict):