This repository has been archived on 2023-03-24. You can view files and clone it, but cannot push or open issues or pull requests.
rustlings-exercises-completed/exercises/threads/threads3.rs

65 lines
1.5 KiB
Rust
Raw Permalink Normal View History

2022-07-15 06:28:49 -05:00
// threads3.rs
// Execute `rustlings hint threads3` or use the `hint` watch subcommand for a hint.
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>) -> () {
let qc = Arc::new(q);
2022-10-16 07:18:56 -05:00
let qc1 = Arc::clone(&qc);
let qc2 = Arc::clone(&qc);
2023-03-24 16:18:51 -05:00
let tx1 = mpsc::Sender::clone(&tx);
let tx2 = mpsc::Sender::clone(&tx);
2022-07-15 06:28:49 -05:00
thread::spawn(move || {
for val in &qc1.first_half {
println!("sending {:?}", val);
2023-03-24 16:18:51 -05:00
tx1.send(*val).unwrap();
2022-07-15 06:28:49 -05:00
thread::sleep(Duration::from_secs(1));
}
});
thread::spawn(move || {
for val in &qc2.second_half {
println!("sending {:?}", val);
2023-03-24 16:18:51 -05:00
tx2.send(*val).unwrap();
2022-07-15 06:28:49 -05:00
thread::sleep(Duration::from_secs(1));
}
});
}
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)
}