spawn_groups 1.1.0

Structured concurrency construct written in Rust, for Rustaceans
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

use crate::shared::Task;

use super::{pair, Suspender};
use std::{
    sync::Arc,
    task::{Context, Poll, Waker},
};

thread_local! {
    pub(crate) static WAKER_PAIR: (Arc<Suspender>, Waker) = {
        pair()
    };
}

#[inline]
pub(crate) fn block_on<T>(mut future: Task<T>, pair: &(Arc<Suspender>, Waker)) -> T {
    let task = Task::from_ref(&mut future);
    let mut context: Context<'_> = Context::from_waker(&pair.1);
    loop {
        match task.poll_task(&mut context) {
            Poll::Pending => pair.0.suspend(),
            Poll::Ready(output) => return output,
        }
    }
}