desync 0.9.0

A hassle-free data type for asynchronous programming
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

use super::job_queue::*;
use super::queue_state::*;

use std::sync::*;
use std::thread::{Thread};
use futures::task::{ArcWake};

///
/// Waker that will wake the specified thread
///
pub (super) struct WakeThread(pub (super) Arc<JobQueue>, pub (super) Thread);

impl ArcWake for WakeThread {
    fn wake_by_ref(arc_self: &Arc<Self>) {
        // Decompose this structure
        let WakeThread(ref queue, ref thread) = **arc_self;

        // Move the queue to the idle state if we can
        {
            let mut queue_core = queue.core.lock().unwrap();

            // Queue can be woken if it's in the WaitingForWake state
            match queue_core.state {
                QueueState::WaitingForWake      => queue_core.state = QueueState::Idle,
                QueueState::WaitingForUnpark    => queue_core.state = QueueState::Running,
                QueueState::Running             => queue_core.state = QueueState::AwokenWhileRunning,
                other_state                     => queue_core.state = other_state
            }
        }

        // Wake the thread
        thread.unpark();
    }
}