dbxs.adapters.async_pool._ConnectionPool

class documentation

class _ConnectionPool: (source)

View In Hierarchy

Database engine and connection pool.

Async Method connect Checkout a new connection from the pool, connecting to the database and opening a thread first if necessary.
Async Method quit Close all outstanding connections and shut down the underlying threadpool.
Async Method _checkin Check a connection back in to the pool, closing and discarding it.
Class Variable _active Undocumented
Class Variable _idlers Undocumented
Class Variable _newConnection Undocumented
Instance Variable _idleMax Undocumented
async def connect(self) -> AsyncConnection: (source)

Checkout a new connection from the pool, connecting to the database and opening a thread first if necessary.

async def quit(self): (source)

Close all outstanding connections and shut down the underlying threadpool.

async def _checkin(self, txn: _PooledConnectionGuard, connection: AsyncConnection): (source)

Check a connection back in to the pool, closing and discarding it.

_active: list[_PooledConnectionGuard] = (source)

Undocumented

_idlers: list[AsyncConnection] = (source)

Undocumented

_newConnection: Callable[[], Awaitable[AsyncConnection]] = (source)

Undocumented

_idleMax: int = (source)

Undocumented