mirror of https://github.com/rust-lang/rustlings
You cannot select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
64 lines
1.3 KiB
Rust
64 lines
1.3 KiB
Rust
// threads3.rs
|
|
//
|
|
// Execute `rustlings hint threads3` or use the `hint` watch subcommand for a
|
|
// hint.
|
|
|
|
// I AM NOT DONE
|
|
|
|
use std::sync::mpsc;
|
|
use std::sync::Arc;
|
|
use std::thread;
|
|
use std::time::Duration;
|
|
|
|
struct Queue {
|
|
length: u32,
|
|
first_half: Vec<u32>,
|
|
second_half: Vec<u32>,
|
|
}
|
|
|
|
impl Queue {
|
|
fn new() -> Self {
|
|
Queue {
|
|
length: 10,
|
|
first_half: vec![1, 2, 3, 4, 5],
|
|
second_half: vec![6, 7, 8, 9, 10],
|
|
}
|
|
}
|
|
}
|
|
|
|
fn send_tx(q: Queue, tx: mpsc::Sender<u32>) -> () {
|
|
thread::spawn(move || {
|
|
for val in q.first_half {
|
|
println!("sending {:?}", val);
|
|
tx.send(val).unwrap();
|
|
thread::sleep(Duration::from_secs(1));
|
|
}
|
|
});
|
|
|
|
thread::spawn(move || {
|
|
for val in q.second_half {
|
|
println!("sending {:?}", val);
|
|
tx.send(val).unwrap();
|
|
thread::sleep(Duration::from_secs(1));
|
|
}
|
|
});
|
|
}
|
|
|
|
#[test]
|
|
fn main() {
|
|
let (tx, rx) = mpsc::channel();
|
|
let queue = Queue::new();
|
|
let queue_length = queue.length;
|
|
|
|
send_tx(queue, tx);
|
|
|
|
let mut total_received: u32 = 0;
|
|
for received in rx {
|
|
println!("Got: {}", received);
|
|
total_received += 1;
|
|
}
|
|
|
|
println!("total numbers received: {}", total_received);
|
|
assert_eq!(total_received, queue_length)
|
|
}
|