arta 0.2.0

Async runtime abstractions library
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

//! Green threads spawning and management.

use futures::Future;

/// Represents a handle to control spawned task execution.
pub trait RuntimeJoinHandle<T>: Future<Output = std::thread::Result<T>>
where
    T: Send + 'static,
{
    /// Cancel this task.
    fn cancel(self) -> impl Future<Output = Option<std::thread::Result<T>>> + Send;
}

/// Represents an async runtime that supports green threads spawning.
pub trait TaskRuntime: Send + Sync {
    /// Handle emitted on thread spawn.
    type JoinHandle<T>: RuntimeJoinHandle<T>
    where
        T: Send + 'static;

    /// Spawn thread.
    fn spawn<R>(&self, future: impl Future<Output = R> + Send + 'static) -> Self::JoinHandle<R>
    where
        R: Send + 'static;

    /// Spawn thread that may block on I/O operation or does some CPU heavy work.
    fn spawn_blocking<R>(&self, task: impl FnOnce() -> R + Send + 'static) -> Self::JoinHandle<R>
    where
        R: Send + 'static;
}