rust/ultimate_rust2
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Improve instructions, fix a function call that had been renamed in one place but not others

Browse Source
This commit is contained in:
Nathan Stocks
2021-11-12 11:32:27 -07:00
parent 7590bcc927
commit e1b22630a6
1 changed files with 38 additions and 36 deletions
Download Patch File Download Diff File Expand all files Collapse all files

72
exercise/threads_channels/src/main.rs
View File

@@ -44,49 +44,51 @@ fn main() {
// 3. Time for some fun with channels!
// - Uncomment the block comment below (Find and remove the `/*` and `*/`).
// - Create variables `tx` and `rx` and assign them to the sending and receiving ends of an
// unbounded channel. Hint: An unbounded channel can be created with `channel::unbounded()`
// unbounded channel. Hint: An unbounded channel can be created with `channel::unbounded()`
/*
// let ...
/*
// let ...
// Cloning a channel makes another variable connected to that end of the channel so that you can
// send it to another thread. We want another variable that can be used for sending...
let tx2 = tx.clone();
// Cloning a channel makes another variable connected to that end of the channel so that you can
// send it to another thread. We want another variable that can be used for sending...
let tx2 = tx.clone();
// 4. Examine the flow of execution of "Thread A" and "Thread B" below. Do you see how their
// output will mix with each other?
// - Increase the value passed to the first `pause_ms()` call in "Thread A" so that both the
// "Thread B" outputs occur before the "Thread A" outputs.
// 4. Examine the flow of execution of "Thread A" and "Thread B" below. Do you see how their
// output will mix with each other?
// - Run this code. Notice the order of output from Thread A and Thread B.
// - Increase the value passed to the first `sleep_ms()` call in Thread A so that both the
// Thread B outputs occur *before* Thread A outputs anything.
// - Run the code again and make sure the output comes in a different order.
// Thread A
let handle_a = thread::spawn(move || {
pause_ms(0);
tx2.send("Thread A: 1").unwrap();
pause_ms(200);
tx2.send("Thread A: 2").unwrap();
});
// Thread A
let handle_a = thread::spawn(move || {
sleep_ms(0);
tx2.send("Thread A: 1").unwrap();
sleep_ms(200);
tx2.send("Thread A: 2").unwrap();
});
pause_ms(100); // Make sure Thread A has time to get going before we spawn Thread B
sleep_ms(100); // Make sure Thread A has time to get going before we spawn Thread B
// Thread B
let handle_b = thread::spawn(move || {
pause_ms(0);
tx.send("Thread B: 1").unwrap();
pause_ms(200);
tx.send("Thread B: 2").unwrap();
});
// Thread B
let handle_b = thread::spawn(move || {
sleep_ms(0);
tx.send("Thread B: 1").unwrap();
sleep_ms(200);
tx.send("Thread B: 2").unwrap();
});
// Using a Receiver channel as an iterator is a convenient way to get values until the channel
// gets closed. A Receiver channel is automatically closed once all Sender channels have been
// closed. Both our threads automatically close their Sender channels when they exit and the
// destructors for the channels get automatically called.
for msg in rx {
println!("Main thread: Received {}", msg);
}
// Using a Receiver channel as an iterator is a convenient way to get values until the channel
// gets closed. A Receiver channel is automatically closed once all Sender channels have been
// closed. Both our threads automatically close their Sender channels when they exit and the
// destructors for the channels get automatically called.
for msg in rx {
println!("Main thread: Received {}", msg);
}
// 5. Oops, we forgot to join "Thread A" and "Thread B". That's bad hygiene!
// - Use the thread handles to join both threads without getting any compiler warnings.
*/
// 5. Oops, we forgot to join "Thread A" and "Thread B". That's bad hygiene!
// - Use the thread handles to join both threads without getting any compiler warnings.
*/
// Challenge: Make two child threads and give them each a receiving end to a channel. From the
// main thread loop through several values and print each out and then send it to the channel.