An asyncio-compatible version of :class:`.QueuePool`. This pool is used by default when using :class:`.AsyncEngine` engines that were generated from :func:`_asyncio.create_async_engine`. It uses an asyncio-compatible queue implementation that does not use ``threading.Lock``.
| 258 | |
| 259 | |
| 260 | class AsyncAdaptedQueuePool(QueuePool): |
| 261 | """An asyncio-compatible version of :class:`.QueuePool`. |
| 262 | |
| 263 | This pool is used by default when using :class:`.AsyncEngine` engines that |
| 264 | were generated from :func:`_asyncio.create_async_engine`. It uses an |
| 265 | asyncio-compatible queue implementation that does not use |
| 266 | ``threading.Lock``. |
| 267 | |
| 268 | The arguments and operation of :class:`.AsyncAdaptedQueuePool` are |
| 269 | otherwise identical to that of :class:`.QueuePool`. |
| 270 | |
| 271 | """ |
| 272 | |
| 273 | _is_asyncio = True |
| 274 | _queue_class: Type[sqla_queue.QueueCommon[ConnectionPoolEntry]] = ( |
| 275 | sqla_queue.AsyncAdaptedQueue |
| 276 | ) |
| 277 | |
| 278 | _dialect = _AsyncConnDialect() |
| 279 | |
| 280 | |
| 281 | class FallbackAsyncAdaptedQueuePool(AsyncAdaptedQueuePool): |
nothing calls this directly
no test coverage detected