Struct Shutter

pub struct Shutter { /* private fields */ }

Examples

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

#[test]
fn test_func() {
  let shutter = Shutter::new();

  shutter.spawn(|| println!("testing"));
  shutter.spawn(|| thread::sleep(Duration::from_millis(300)));

  shutter.timeout(Duration::from_millis(500));
}

Implementations

impl Shutter

pub fn new() -> Self

Create a shutter.

pub fn spawn<F, T>(&self, f: F) -> JoinHandle<T>

where F: FnOnce() -> T + Send + 'static, T: Send + 'static,

Spawn a thread and track it.

pub fn timeout(&self, dur: Duration)

Ensure every spawned threads are not blocked after given duration.

Returns early if every spawned threads are terminated.

Panics

It panics after given duration if at least one thread spawned by this shutter is blocked.

Trait Implementations

impl Debug for Shutter

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

Formats the value using the given formatter.