[go: up one dir, main page]

flume 0.8.3

A blazingly fast multi-producer channel
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

use std::{thread::{self, Thread}, time::Duration, any::Any};

pub trait Signal: Send + Sync + 'static {
    fn fire(&self);
    fn as_any(&self) -> &(dyn Any + 'static);
}

pub struct SyncSignal(Thread);

impl Default for SyncSignal {
    fn default() -> Self {
        Self(thread::current())
    }
}

impl Signal for SyncSignal {
    fn as_any(&self) -> &(dyn Any + 'static) { self }
    fn fire(&self) { self.0.unpark(); }
}

impl SyncSignal {
    pub fn wait(&self) { thread::park(); }
    pub fn wait_timeout(&self, dur: Duration) { thread::park_timeout(dur); }
}