Struct LowLatencyResourcePool 

pub struct LowLatencyResourcePool<T: Send + 'static> { /* private fields */ }

ロックフリーなリソース借用プール。

Tokio の非同期スケジューラ上で許可証を獲得後、RAII ガード構造体として リソースを取り出し、spawn_blocking などのスレッド境界を越えて安全に転送可能にする。

Implementations

impl<T: Send + 'static> LowLatencyResourcePool<T>

pub fn new(items: Vec<T>) -> Self

リソースリストからプールを新規作成する。

引数

• items: プールに初期格納するリソース一覧。

pub fn capacity(&self) -> usize

プールの最大キャパシティを取得する。

pub fn available(&self) -> usize

現在キュー内で待機中の利用可能リソース数を取得する。

pub async fn acquire( &self, timeout: Duration, ) -> Result<PooledResource<T>, PoolError>

ハードタイムアウト付きでリソースを非同期借用する。

Tokio 非同期コンテキストでセマフォ許可証を取得後、キューから pop する。 返却された PooledResource は 'static であり、spawn_blocking への転送が可能である。

引数

• timeout: 取得待機タイムアウト時間。

Trait Implementations

impl<T: Clone + Send + 'static> Clone for LowLatencyResourcePool<T>

fn clone(&self) -> LowLatencyResourcePool<T>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T: Debug + Send + 'static> Debug for LowLatencyResourcePool<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.