source: doc/papers/concurrency/examples/channels.rs @ 5e81a9c

#![feature(async_await)]

use std::thread;
use std::sync::mpsc;

fn main() {
        let (tx1, rx1) = mpsc::channel();
        let (tx2, rx2) = mpsc::channel();
        let (tx3, rx3) = mpsc::channel();
        let (tx4, rx4) = mpsc::channel();
        struct Msg { i : i64,  j : i64 }
        let th = thread::spawn( || {
                let i : i64; let f : f64; let m : Msg;
                loop {
                        select! {
                                i = rx1.recv() => println( i );
                                f = rx2.recv() => println( f );
                                m = rx3.recv() => println( m );
                                _ = rx4.recv() => break;
                        }
                }
        });

        tx1.send( 0 ); // different messages
        tx2.send( 2.5 );
        tx3.send( Msg { i:1, j:2 } );
        tx4.send( "done" );
        th.join().unwrap();
}

// Local Variables: //
// tab-width: 4 //
// compile-command: "rustc -C opt-level=3 channels.rs" //
// End: //