diff options
| author | mokou <mokou@fastmail.com> | 2022-07-15 14:31:49 +0200 |
|---|---|---|
| committer | mokou <mokou@fastmail.com> | 2022-07-15 14:31:49 +0200 |
| commit | c791cf4232fbfc313279b19b483c1adbca1c6862 (patch) | |
| tree | 655ad6c9d33dab11dfd70f28d0ec29d03749a70b /exercises/threads/threads2.rs | |
| parent | f1c4caa37fe5027d121aec6433dee85433d9329d (diff) | |
| parent | c265b681b188ea21b3f8585e65ea363fc02c4b50 (diff) | |
Merge branch '5.0-dev'
Diffstat (limited to 'exercises/threads/threads2.rs')
| -rw-r--r-- | exercises/threads/threads2.rs | 34 |
1 files changed, 34 insertions, 0 deletions
diff --git a/exercises/threads/threads2.rs b/exercises/threads/threads2.rs new file mode 100644 index 0000000..d0f8578 --- /dev/null +++ b/exercises/threads/threads2.rs @@ -0,0 +1,34 @@ +// threads2.rs +// Execute `rustlings hint threads2` or use the `hint` watch subcommand for a hint. +// Building on the last exercise, we want all of the threads to complete their work but this time +// the spawned threads need to be in charge of updating a shared value: JobStatus.jobs_completed + +// I AM NOT DONE + +use std::sync::Arc; +use std::thread; +use std::time::Duration; + +struct JobStatus { + jobs_completed: u32, +} + +fn main() { + let status = Arc::new(JobStatus { jobs_completed: 0 }); + let mut handles = vec![]; + for _ in 0..10 { + let status_shared = status.clone(); + let handle = thread::spawn(move || { + thread::sleep(Duration::from_millis(250)); + // TODO: You must take an action before you update a shared value + status_shared.jobs_completed += 1; + }); + handles.push(handle); + } + for handle in handles { + handle.join().unwrap(); + // TODO: Print the value of the JobStatus.jobs_completed. Did you notice anything + // interesting in the output? Do you have to 'join' on all the handles? + println!("jobs completed {}", ???); + } +} |
