A test of a million communications between channels.

channel_1m.go

import (
    "fmt"
)

func main() {
    num := 1000000
    tots := 0
    bg_chan := make(chan int, num)
    fg_chan := make(chan int, num)

    go func() {
        for i := 0; i < num; i++ {
            bg_chan <- i
            <-fg_chan
        }
    }()

    for i := 0; i < num; i++ {
        tots += <- bg_chan
        fg_chan <- i
    }

    fmt.Println(tots)
}

channel_1m.rs

fn main() {
    let (to_port, to_chan): (Port<int>, Chan<int>) = Chan::new();
    let (from_port, from_chan): (Port<int>, Chan<int>) = Chan::new();
    let mut tots: int = 0;
    let num = 1000000;

    do spawn {
        for _ in range(0, num) {
            from_chan.send(to_port.recv());
        }
    }

    for i in range(0, num) {
        to_chan.send(i);
        tots += from_port.recv();
    }

    println(tots.to_str());
}