go-lib 0.2.0

rust native goroutines
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

// SPDX-License-Identifier: Apache-2.0
//! hello — goroutines and channels in ten lines.
//!
//! Demonstrates the basic pattern: spawn goroutines with `go!`, communicate
//! through unbuffered channels, and receive in the main goroutine.
//!
//! Run with:
//!   cargo run --example hello

use go_lib::{chan::chan, go};

fn main() {
    const N: usize = 5;

    go_lib::run(|| {
        let (tx, rx) = chan::<String>(0); // unbuffered (synchronous)

        // Spawn N goroutines, each sending a greeting.
        for i in 0..N {
            let tx = tx.clone();
            go!(move || {
                tx.send(format!("hello from goroutine {i}"));
            });
        }
        drop(tx); // drop the original; goroutine clones are still live

        // Receive exactly N greetings (order is non-deterministic).
        for _ in 0..N {
            if let Some(msg) = rx.recv() {
                println!("{msg}");
            }
        }
        println!("all goroutines finished");
    });
}