相关 Crates

示例

优雅关闭

let top_permit = permit::Permit::new();
// Start some worker threads.
for _ in 0..5 {
    let permit = top_permit.new_sub();
    std::thread::spawn(move || {
        while !permit.is_revoked() {
            // ...
        }
    });
}
wait_for_shutdown_signal();
// Revoke all thread permits and wait for them to
// finish and drop their permits.
top_permit
    .revoke()
    .wait_subs_timeout(Duration::from_secs(3))
    .unwrap();

Cargo Geiger 安全报告

Metric output format: x/y
    x = unsafe code used by the build
    y = total unsafe code found in the crate

Symbols: 
    🔒  = No `unsafe` usage found, declares #![forbid(unsafe_code)]
    ❓  = No `unsafe` usage found, missing #![forbid(unsafe_code)]
    ☢️  = `unsafe` usage found

Functions  Expressions  Impls  Traits  Methods  Dependency

0/0        0/0          0/0    0/0     0/0      🔒  permit 0.2.1

0/0        0/0          0/0    0/0     0/0    

变更日志

• v0.2.1 - 修复了 sleep 和 sleep_until 有时不会提前返回的问题。
• v0.2.0
  • 将 try_wait_for 重命名为 wait_subs_timeout
  • 将 try_wait_until 重命名为 wait_subs_deadline
  • 在 wait* 方法中将自旋锁替换为 Condvar
  • 移除 wait
  • 添加 sleep 和 sleep_until
• v0.1.5 - 实现 Debug
• v0.1.4 - 修复了 bug，其中 revoke() 和然后 wait() 不会等待。
• v0.1.3
  • 不要保留或唤醒过时的 std::task::Waker 结构。
  • 消除导致不必要的唤醒的竞争条件。
• v0.1.2 - 实现 Future
• v0.1.1 - 使 revoke 返回 &Self
• v0.1.0 - 初始版本

许可协议：Apache-2.0