minions 0.2.6

Experimental actor library, under constant development.
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
38
39
40
41
42
43
44
45
46
47
48
49
50

use std::time::Duration;
use std::sync::Arc;
use parking_lot::{Mutex, Condvar};
use time;

#[derive(Clone)]
pub struct Event {
  condvar : Arc<(Mutex<u64>, Condvar)>,
}

impl Event {
  pub fn notify(&mut self) {
    let &(ref lock, ref cvar) = &*(self.condvar);
    let mut started = lock.lock();
    *started += 1;
    cvar.notify_one();
  }

  pub fn ready(&self, ticket: u64) -> (bool, u64) {
    let &(ref lock, ref _cvar) = &*(self.condvar);
    let started = lock.lock();
    (*started > ticket, *started)
  }

  pub fn wait(&mut self, ticket: u64, timeout_usec: u64) -> u64 {
    // wait for the thread to start up
    let start_at = time::precise_time_ns();
    let &(ref lock, ref cvar) = &*(self.condvar);

    loop {
      let mut locked_ticket = lock.lock();
      if *locked_ticket > ticket {
        return *locked_ticket;
      }

      cvar.wait_for(&mut locked_ticket, Duration::new(timeout_usec/1000_000, ((timeout_usec%1000_000) as u32) *1000 ));

      let now = time::precise_time_ns();
      if now > start_at+(1000*timeout_usec) {
        return *locked_ticket;
      }
    }
  }
}

pub fn new() -> Event {
  Event {
    condvar: Arc::new((Mutex::new(0u64), Condvar::new())),
  }
}