async-lock 2.8.0

Async synchronization primitives
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

use std::sync::atomic::{AtomicBool, Ordering};
use std::sync::Arc;
use std::task::Context;

use futures_lite::prelude::*;
use waker_fn::waker_fn;

pub fn check_yields_when_contended<G>(
    contending_guard: G,
    mut acquire_future: impl Future + Unpin,
) {
    let was_woken = Arc::new(AtomicBool::new(false));
    let waker = {
        let was_woken = Arc::clone(&was_woken);
        waker_fn(move || was_woken.store(true, Ordering::SeqCst))
    };
    let mut cx = Context::from_waker(&waker);

    assert!(acquire_future.poll(&mut cx).is_pending());
    drop(contending_guard);
    assert!(was_woken.load(Ordering::SeqCst));
    assert!(acquire_future.poll(&mut cx).is_ready());
}