go-lib 0.6.1

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

// 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};

#[go_lib::main]
fn main() {
    const N: usize = 5;

    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");
}