Guest User

Untitled

a guest
Jul 17th, 2018
64
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.32 KB | None | 0 0
  1. use std::thread;
  2. use std::sync::mpsc::channel;
  3.  
  4. fn main() {
  5.  
  6. let (tx, rx) = channel();
  7. for i in 0..10 {
  8. let tx = tx.clone();
  9. thread::spawn(move|| {
  10. tx.send(i).unwrap();
  11. });
  12. }
  13.  
  14. for _ in 0..10 {
  15. let j = rx.recv().unwrap();
  16. assert!(0 <= j && j < 10);
  17. }
  18. }
Add Comment
Please, Sign In to add comment