结构体 SemaphorePermit

Source

pub struct SemaphorePermit<'a> { /* private fields */ }

展开描述

来自 semaphore 的 permit。

此类型由 acquire 方法创建。

实现§

Source §

impl<'a> SemaphorePermit<'a>

Source

pub fn forget(self)

放弃许可证而不会将其释放回信号量。这可用于减少信号量中可用的许可证数量。

§示例

use std::sync::Arc;


use tokio::sync::Semaphore;





let sem = Arc::new(Semaphore::new(10));


{


    let permit = sem.try_acquire_many(5).unwrap();


    assert_eq!(sem.available_permits(), 5);


    permit.forget();


}





// Since we forgot the permit, available permits won't go back to its initial value


// even after the permit is dropped.


assert_eq!(sem.available_permits(), 5);

Source

pub fn merge(&mut self, other: Self)

将两个 SemaphorePermit 实例合并在一起，消耗 other 而不释放其持有的许可证。

self 和 other 持有的许可证都会在 self 丢弃时释放。

§Panics

如果合并来自不同 Semaphore 实例的许可证，此函数会 panic。

§示例

use std::sync::Arc;


use tokio::sync::Semaphore;





let sem = Arc::new(Semaphore::new(10));


let mut permit = sem.try_acquire().unwrap();





for _ in 0..9 {


    let _permit = sem.try_acquire().unwrap();


    // Merge individual permits into a single one.


    permit.merge(_permit)


}





assert_eq!(sem.available_permits(), 0);





// Release all permits in a single batch.


drop(permit);





assert_eq!(sem.available_permits(), 10);

Source

pub fn split(&mut self, n: usize) -> Option<Self>

从 self 中拆分 n 个许可证，并返回持有 n 个许可证的新 SemaphorePermit 实例。

如果没有足够的许可证且无法减少 n，则返回 None。

§示例

use std::sync::Arc;


use tokio::sync::Semaphore;





let sem = Arc::new(Semaphore::new(3));





let mut p1 = sem.try_acquire_many(3).unwrap();


let p2 = p1.split(1).unwrap();





assert_eq!(p1.num_permits(), 2);


assert_eq!(p2.num_permits(), 1);