Now std::thread::sleep is used together with std::time::Duration::from_millis.
use std::sync::{Arc, Mutex};
use std::thread;
use std::sync::{Arc, Mutex};
use std::thread;
+use std::time::Duration;
// The derived `Clone` implementation will clone the `Arc`, so all clones will actually talk about the same counter.
// The derived `Clone` implementation will clone the `Arc`, so all clones will actually talk about the same counter.
let counter1 = counter.clone();
let handle1 = thread::spawn(move || {
for _ in 0..10 {
let counter1 = counter.clone();
let handle1 = thread::spawn(move || {
for _ in 0..10 {
+ thread::sleep(Duration::from_millis(15));
counter1.increment(2);
}
});
counter1.increment(2);
}
});
let counter2 = counter.clone();
let handle2 = thread::spawn(move || {
for _ in 0..10 {
let counter2 = counter.clone();
let handle2 = thread::spawn(move || {
for _ in 0..10 {
+ thread::sleep(Duration::from_millis(20));
counter2.increment(3);
}
});
// Now we watch the threads working on the counter.
for _ in 0..50 {
counter2.increment(3);
}
});
// Now we watch the threads working on the counter.
for _ in 0..50 {
+ thread::sleep(Duration::from_millis(5));
println!("Current value: {}", counter.get());
}
println!("Current value: {}", counter.get());
}