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
26
27
28
29
30
31
32
33
34
35

use std::{
    future::Future,
    sync::{Arc, Barrier},
};

use crate::threadpool_impl::TaskPriority;

use super::{task::Task, task_enum::TaskOrBarrier};

pub(crate) struct PrioritizedTask<T> {
    pub(crate) task: TaskOrBarrier<T>,
    priority: TaskPriority,
}

impl<T> PrioritizedTask<T> {
    pub(crate) fn priority(&self) -> TaskPriority {
        self.priority.clone()
    }
}

impl<T> PrioritizedTask<T> {
    pub(crate) fn new(priority: TaskPriority, future: impl Future<Output = T>) -> Self {
        Self {
            task: TaskOrBarrier::Task(Task::new(future)),
            priority,
        }
    }

    pub(crate) fn new_with(barrier: Arc<Barrier>) -> Self {
        Self {
            task: TaskOrBarrier::Barrier(barrier),
            priority: TaskPriority::Wait,
        }
    }
}