Method notify_many

tensorrt_llm/llmapi/utils.py:484–492

Notify the events in the loop.

(loop: asyncio.AbstractEventLoop,
                    queues: List["_SyncQueue"])

    @staticmethod
    def notify_many(loop: asyncio.AbstractEventLoop,
                    queues: List["_SyncQueue"]) -> None:
        """ Notify the events in the loop. """

        if loop.is_running():
            asyncio.run_coroutine_threadsafe(
                _SyncQueue._notify_many(frozenset(queues)), loop)
        else:
            raise AsyncQueue.EventLoopShutdownError()

    @property
    def loop(self) -> asyncio.AbstractEventLoop: