1
0
Fork 0
mirror of https://github.com/notohh/rustlings.git synced 2024-12-22 00:18:09 -05:00
rustlings/exercises/20_threads/threads3.rs

65 lines
1.5 KiB
Rust
Raw Normal View History

2024-07-01 05:23:40 -04:00
use std::{sync::mpsc, thread, time::Duration};
2022-07-15 07:28:49 -04:00
struct Queue {
length: u32,
first_half: Vec<u32>,
second_half: Vec<u32>,
}
impl Queue {
fn new() -> Self {
2024-07-01 05:23:40 -04:00
Self {
2022-07-15 07:28:49 -04:00
length: 10,
first_half: vec![1, 2, 3, 4, 5],
second_half: vec![6, 7, 8, 9, 10],
}
}
}
2024-07-01 05:23:40 -04:00
fn send_tx(q: Queue, tx: mpsc::Sender<u32>) {
// TODO: We want to send `tx` to both threads. But currently, it is moved
2024-07-02 08:28:08 -04:00
// into the first thread. How could you solve this problem?
2022-07-15 07:28:49 -04:00
thread::spawn(move || {
2024-03-17 20:12:37 -04:00
for val in q.first_half {
2024-07-01 05:23:40 -04:00
println!("Sending {val:?}");
2024-03-17 20:12:37 -04:00
tx.send(val).unwrap();
2024-07-01 05:23:40 -04:00
thread::sleep(Duration::from_millis(250));
2022-07-15 07:28:49 -04:00
}
});
thread::spawn(move || {
2024-03-17 20:12:37 -04:00
for val in q.second_half {
2024-07-01 05:23:40 -04:00
println!("Sending {val:?}");
2024-03-17 20:12:37 -04:00
tx.send(val).unwrap();
2024-07-01 05:23:40 -04:00
thread::sleep(Duration::from_millis(250));
2022-07-15 07:28:49 -04:00
}
});
}
fn main() {
2024-04-17 17:34:27 -04:00
// You can optionally experiment here.
}
2022-07-15 07:28:49 -04:00
2024-04-17 17:34:27 -04:00
#[cfg(test)]
mod tests {
use super::*;
2022-07-15 07:28:49 -04:00
2024-04-17 17:34:27 -04:00
#[test]
fn threads3() {
let (tx, rx) = mpsc::channel();
let queue = Queue::new();
let queue_length = queue.length;
send_tx(queue, tx);
2022-07-15 07:28:49 -04:00
2024-04-17 17:34:27 -04:00
let mut total_received: u32 = 0;
for received in rx {
2024-07-01 05:23:40 -04:00
println!("Got: {received}");
2024-04-17 17:34:27 -04:00
total_received += 1;
}
2024-07-01 05:23:40 -04:00
println!("Number of received values: {total_received}");
2024-05-22 09:13:18 -04:00
assert_eq!(total_received, queue_length);
2024-04-17 17:34:27 -04:00
}
2022-07-15 07:28:49 -04:00
}