async-task 1.3.1

Task abstraction for building executors
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

use std::sync::atomic::{AtomicUsize, Ordering};
use std::sync::Arc;

#[test]
fn wake() {
    let a = Arc::new(AtomicUsize::new(0));
    let w = async_task::waker_fn({
        let a = a.clone();
        move || {
            a.fetch_add(1, Ordering::SeqCst);
        }
    });

    assert_eq!(a.load(Ordering::SeqCst), 0);
    w.wake_by_ref();
    assert_eq!(a.load(Ordering::SeqCst), 1);

    let w2 = w.clone();
    assert_eq!(a.load(Ordering::SeqCst), 1);
    w2.wake_by_ref();
    assert_eq!(a.load(Ordering::SeqCst), 2);
    drop(w2);
    assert_eq!(a.load(Ordering::SeqCst), 2);

    let w3 = w.clone();
    assert_eq!(a.load(Ordering::SeqCst), 2);
    w3.wake();
    assert_eq!(a.load(Ordering::SeqCst), 3);
}