Function unbounded_spsc::channel

source · 
pub fn channel<T: 'static>() -> (Sender<T>, Receiver<T>)
Examples found in repository?
examples/parallel-recv.rs (line 59)
57
58
59
60
61
62
63
64
65

fn main() {
  println!("main...");
  let (sender, receiver) = unbounded_spsc::channel();
  let join_sender = std::thread::spawn (move || sendfun (sender));
  let join_receiver = std::thread::spawn (move || recvfun (receiver));
  join_sender.join().unwrap();
  join_receiver.join().unwrap();
  println!("...main");
}
More examples
Hide additional examples
examples/parallel-try_recv.rs (line 60)
58
59
60
61
62
63
64
65
66

fn main() {
  println!("main...");
  let (sender, receiver) = unbounded_spsc::channel();
  let join_sender = std::thread::spawn (move || sendfun (sender));
  let join_receiver = std::thread::spawn (move || recvfun (receiver));
  join_sender.join().unwrap();
  join_receiver.join().unwrap();
  println!("...main");
}
examples/sequential-recv.rs (line 48)
46
47
48
49
50
51
52
53
54

fn main() {
  println!("main...");
  let (sender, receiver) = unbounded_spsc::channel();
  let join_sender = std::thread::spawn (move || sendfun (sender));
  join_sender.join().unwrap();
  let join_receiver = std::thread::spawn (move || recvfun (receiver));
  join_receiver.join().unwrap();
  println!("...main");
}
examples/sequential-try_recv.rs (line 49)
47
48
49
50
51
52
53
54
55

fn main() {
  println!("main...");
  let (sender, receiver) = unbounded_spsc::channel();
  let join_sender = std::thread::spawn (move || sendfun (sender));
  join_sender.join().unwrap();
  let join_receiver = std::thread::spawn (move || recvfun (receiver));
  join_receiver.join().unwrap();
  println!("...main");
}