(queues: Iterable["_SyncQueue"])
| 477 | # Notify many queues in one coroutine, to cut down context switch overhead. |
| 478 | @staticmethod |
| 479 | async def _notify_many(queues: Iterable["_SyncQueue"]): |
| 480 | for queue in queues: |
| 481 | queue._aq.notify() |
| 482 | |
| 483 | @staticmethod |
| 484 | def notify_many(loop: asyncio.AbstractEventLoop, |