From 9108553a2ed71896faceda67199dbd508da893d3 Mon Sep 17 00:00:00 2001
From: tjcardinal <tylerjcardinal@gmail.com>
Date: Sun, 16 May 2021 01:31:29 -0500
Subject: [PATCH] Complete thread exercises
---
exercises/threads/threads1.rs | 10 +++++-----
1 file changed, 5 insertions(+), 5 deletions(-)
diff --git a/exercises/threads/threads1.rs b/exercises/threads/threads1.rs
index f31b317..b1a5665 100644
--- a/exercises/threads/threads1.rs
+++ b/exercises/threads/threads1.rs
@@ -6,9 +6,8 @@
// of "waiting..." and the program ends without timing out when running,
// you've got it :)
-// I AM NOT DONE
-
use std::sync::Arc;
+use std::sync::Mutex;
use std::thread;
use std::time::Duration;
@@ -17,15 +16,16 @@ struct JobStatus {
}
fn main() {
- let status = Arc::new(JobStatus { jobs_completed: 0 });
+ let status = Arc::new(Mutex::new(JobStatus { jobs_completed: 0 }));
let status_shared = status.clone();
thread::spawn(move || {
for _ in 0..10 {
thread::sleep(Duration::from_millis(250));
- status_shared.jobs_completed += 1;
+
+ status_shared.lock().unwrap().jobs_completed += 1;
}
});
- while status.jobs_completed < 10 {
+ while status.lock().unwrap().jobs_completed < 10 {
println!("waiting... ");
thread::sleep(Duration::from_millis(500));
}