结构体 OwnedSemaphorePermit 

pub struct OwnedSemaphorePermit { /* private fields */ }

来自 semaphore 的 owned permit。

此类型 由 acquire_owned 方法 创建。

实现

impl OwnedSemaphorePermit

pub fn forget(self)

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

示例

use std::sync::Arc;

use tokio::sync::Semaphore;



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

{

    let permit = sem.clone().try_acquire_many_owned(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);

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

将两个 OwnedSemaphorePermit 实例合并在一起，消耗 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.clone().try_acquire_owned().unwrap();



for _ in 0..9 {

    let _permit = sem.clone().try_acquire_owned().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);

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

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

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

Note

它会克隆拥有的 Arc 以构造新实例。

示例

use std::sync::Arc;

use tokio::sync::Semaphore;



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



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

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



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

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

pub fn semaphore(&self) -> &Arc<Semaphore>

返回此许可证的来源 Semaphore。

pub fn num_permits(&self) -> usize

返回 self 持有的许可证数量。

Trait 实现

impl Debug for OwnedSemaphorePermit

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

使用给定的格式化器格式化此值。 更多信息

impl Drop for OwnedSemaphorePermit

fn drop(&mut self)

执行此类型的析构函数。 更多信息