gorust 0.1.0

Go-style concurrency in Rust - bringing Go-style concurrency patterns to Rust with familiar primitives like goroutines and channels
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

use gorust::{Channel, Runtime, go};

fn main() {
    // 初始化运行时
    Runtime::init();

    // 测试 goroutine
    go(|| {
        println!("Hello from goroutine 1!");
    });

    go(|| {
        println!("Hello from goroutine 2!");
    });

    // 测试无缓冲通道
    let ch = Channel::<i32>::new(0);
    let ch_snd = ch.clone();
    go(move || {
        println!("Sending value 42...");
        ch_snd.send(42).unwrap();
        println!("Value sent!");
    });

    let ch_rcv = ch.clone();
    go(move || {
        let value = ch_rcv.recv().unwrap();
        println!("Received value: {}", value);
    });

    // 测试有缓冲通道
    let ch2 = Channel::<String>::new(10);
    ch2.send("Hello".to_string()).unwrap();
    let received = ch2.recv().unwrap();
    println!("Buffered channel test: {}", received);

    println!("All tests scheduled!");

    // 等待所有 goroutine 完成
    Runtime::wait_for_all();

    // 清理运行时
    Runtime::shutdown();
}