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
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
//! # Multi-threading task facility building on cooperative stackful coroutine
//! `stuck` provides a multi-threading runtime to serve lightweight concurrent tasks where you can
//! use [coroutine::suspension] to cooperatively resume suspending coroutines.
//!
//! ## Usage
//! Construct an [runtime::Runtime] to [runtime::Runtime::spawn] initial task.
//!
//! ### Task
//! * Use [task::spawn] to spawn new task in running task. The spawned task will run concurrent
//! with all other tasks.
//! * Use [task::session] to create facilities to wake waiting tasks.
//! * Use [task::JoinHandle] to join task result.
//!
//! ### Coroutine
//! * Use [coroutine::spawn] to spawn new coroutine in running task. The spawned coroutine will run
//! cooperatively with other coroutines belonging to same task.
//! * Use [coroutine::suspension] to create facilities to resume suspending coroutines.
//! * Use [coroutine::JoinHandle] to join coroutine result.
//!
//! ## Example
//! ```rust
//! use std::time::Duration;
//!
//! use stuck::channel::parallel;
//! use stuck::channel::prelude::*;
//! use stuck::{select, task, time};
//!
//! #[stuck::main]
//! fn main() {
//! let (mut request_sender, request_receiver) = parallel::bounded(1);
//! let (mut response_sender, mut response_receiver) = parallel::bounded(1);
//!
//! task::spawn(move || {
//! for value in request_receiver.into_iter() {
//! time::sleep(Duration::from_secs(1));
//! response_sender.send(value - 1).unwrap();
//! }
//! });
//!
//! let mut tasks = vec![6, 6, 6, 6];
//!
//! let mut sum = 0;
//! loop {
//! select! {
//! r = <-response_receiver => if let Some(n) = r {
//! sum += n;
//! },
//! _ = request_sender<-tasks.pop().unwrap(), if !tasks.is_empty() => if tasks.is_empty() {
//! request_sender.close();
//! },
//! complete => break,
//! }
//! }
//! println!("sum: {}", sum);
//! assert_eq!(sum, 20);
//! }
//! ```
pub use StackSize;
pub use JoinError;
pub use main;
pub use test;