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
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

// SPDX-License-Identifier: Apache-2.0
//! select_fanin — fan-in multiplexing with `select!`.
//!
//! Two producers send values at different rates.  A single consumer uses
//! `select!` to receive from whichever producer is ready first, merging
//! both streams into one.  This is the "fan-in" pattern from Go's concurrency
//! tutorial.
//!
//! Run with:
//!   cargo run --example select_fanin

use std::time::Duration;
use go_lib::{chan::chan, go, select};

fn main() {
    go_lib::run(|| {
        // Two buffered channels — producers fill them at their own pace.
        let (fast_tx, fast_rx) = chan::<i32>(8);
        let (slow_tx, slow_rx) = chan::<i32>(4);

        // Fast producer: 6 values, 5 ms apart.
        go!(move || {
            for i in 0..6_i32 {
                go_lib::sleep(Duration::from_millis(5));
                fast_tx.send(i);
            }
        });

        // Slow producer: 3 values, 15 ms apart.
        go!(move || {
            for i in 10..13_i32 {
                go_lib::sleep(Duration::from_millis(15));
                slow_tx.send(i);
            }
        });

        // Consumer: receive exactly 9 values from whichever channel is ready.
        let mut received = Vec::new();
        for _ in 0..9 {
            select! {
                recv(fast_rx) -> v => {
                    if let Some(n) = v { received.push(('F', n)); }
                }
                recv(slow_rx) -> v => {
                    if let Some(n) = v { received.push(('S', n)); }
                }
            }
        }

        println!("received {} values in arrival order:", received.len());
        for (src, val) in &received {
            println!("  {src}: {val}");
        }

        let fast_count = received.iter().filter(|(s, _)| *s == 'F').count();
        let slow_count = received.iter().filter(|(s, _)| *s == 'S').count();
        println!("fast={fast_count} slow={slow_count}");
        assert_eq!(fast_count, 6);
        assert_eq!(slow_count, 3);
    });
}