fibre 0.5.8

High-performance, safe, memory-efficient sync/async channels built for real-time, low-overhead communication in concurrent Rust applications.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37

//! Utilities for synchronous blocking and parking.
//! For now, these are minimal helpers around std::thread::park/unpark.
//! The channel implementations will manage the state.

use std::thread;
use std::time::Duration;

/// Parks the current thread.
#[inline]
pub(crate) fn park_thread() {
  thread::park();
}

/// Parks the current thread for a given duration.
#[inline]
pub(crate) fn park_thread_timeout(duration: Duration) {
  thread::park_timeout(duration);
}

/// Unparks the given thread.
#[inline]
pub(crate) fn unpark_thread(thread: &thread::Thread) {
  thread.unpark();
}

pub fn park_thread_timeout_cond<F>(timeout: Option<Duration>, stop_condition: F)
where
  F: Fn() -> bool,
{
  if stop_condition() {
    return;
  }
  match timeout {
    Some(t) => thread::park_timeout(t),
    None => thread::park(),
  }
}