pub struct Pool<M: Manager, W: From<Object<M>> = Object<M>> { /* private fields */ }
Expand description
Generic object and connection pool.
This struct can be cloned and transferred across thread boundaries and uses reference counting for its internal state.
Implementations§
Source§impl<M: Manager, W: From<Object<M>>> Pool<M, W>
impl<M: Manager, W: From<Object<M>>> Pool<M, W>
Sourcepub fn builder(manager: M) -> PoolBuilder<M, W>
pub fn builder(manager: M) -> PoolBuilder<M, W>
Sourcepub fn resize(&self, max_size: usize)
pub fn resize(&self, max_size: usize)
Resize the pool. This change the max_size
of the pool dropping
excess objects and/or making space for new ones.
If the pool is closed this method does nothing. The Pool::status
method
always reports a max_size
of 0 for closed pools.
Sourcepub fn retain(&self, f: impl Fn(&M::Type, Metrics) -> bool)
pub fn retain(&self, f: impl Fn(&M::Type, Metrics) -> bool)
Retains only the objects specified by the given function.
This function is typically used to remove objects from the pool based on their current state or metrics.
Caution: This function blocks the entire pool while it is running. Therefore the given function should not block.
The following example starts a background task that runs every 30 seconds and removes objects from the pool that haven’t been used for more than one minute.
let interval = Duration::from_secs(30);
let max_age = Duration::from_secs(60);
tokio::spawn(async move {
loop {
tokio::time::sleep(interval).await;
pool.retain(|_, metrics| metrics.last_used() < max_age);
}
});
Sourcepub fn close(&self)
pub fn close(&self)
Closes this Pool
.
All current and future tasks waiting for Object
s will return
PoolError::Closed
immediately.
This operation resizes the pool to 0.