use std::sync::{Arc, RwLock};
use std::thread;
+use std::time::Duration;
#[derive(Clone)]
pub struct ConcurrentCounter(Arc<RwLock<usize>>);
let counter1 = counter.clone();
let handle1 = thread::spawn(move || {
for _ in 0..10 {
- thread::sleep_ms(15);
+ thread::sleep(Duration::from_millis(15));
counter1.increment(2);
}
});
let counter2 = counter.clone();
let handle2 = thread::spawn(move || {
for _ in 0..10 {
- thread::sleep_ms(20);
+ thread::sleep(Duration::from_millis(20));
counter2.increment(3);
}
});
// Now we want to watch the threads working on the counter.
for _ in 0..50 {
- thread::sleep_ms(5);
+ thread::sleep(Duration::from_millis(5));
println!("Current value: {}", counter.get());
}
// Notice that I called the function on `SomethingOrNothing` `print2` to disambiguate from the `print` defined previously.
//
// *Hint*: There is a macro `print!` for printing without appending a newline.
-trait Print {
+pub trait Print {
/* Add things here */
}
impl<T: Print> SomethingOrNothing<T> {
use std::sync::{Arc, Mutex};
use std::thread;
+use std::time::Duration;
//@ We already saw that we can use `Arc` to share memory between threads. However, `Arc` can only provide *read-only*
//@ access to memory: Since there is aliasing, Rust cannot, in general, permit mutation. To implement shared-memory
let counter1 = counter.clone();
let handle1 = thread::spawn(move || {
for _ in 0..10 {
- thread::sleep_ms(15);
+ thread::sleep(Duration::from_millis(15));
counter1.increment(2);
}
});
let counter2 = counter.clone();
let handle2 = thread::spawn(move || {
for _ in 0..10 {
- thread::sleep_ms(20);
+ thread::sleep(Duration::from_millis(20));
counter2.increment(3);
}
});
// Now we watch the threads working on the counter.
for _ in 0..50 {
- thread::sleep_ms(5);
+ thread::sleep(Duration::from_millis(5));
println!("Current value: {}", counter.get());
}