diff options
| -rw-r--r-- | examples/list.rs | 53 |
1 files changed, 53 insertions, 0 deletions
diff --git a/examples/list.rs b/examples/list.rs new file mode 100644 index 0000000..904d9f2 --- /dev/null +++ b/examples/list.rs @@ -0,0 +1,53 @@ +use std::thread; + +use happylock::mutex::Mutex; +use happylock::{LockGuard, ThreadKey}; + +const N: usize = 10; + +static DATA: [Mutex<usize>; 6] = [ + Mutex::new(0), + Mutex::new(1), + Mutex::new(2), + Mutex::new(3), + Mutex::new(4), + Mutex::new(5), +]; + +static SEED: Mutex<u32> = Mutex::new(42); + +fn random(key: ThreadKey) -> (ThreadKey, usize) { + let mut seed = SEED.lock(key); + let x = *seed; + let x = x ^ (x << 13); + let x = x ^ (x >> 17); + let x = x ^ (x << 5); + *seed = x; + (Mutex::unlock(seed), x as usize) +} + +fn main() { + for _ in 0..N { + thread::spawn(move || { + let mut key = ThreadKey::lock().unwrap(); + let mut rand; + let mut data = Vec::new(); + for _ in 0..3 { + (key, rand) = random(key); + data.push(&DATA[rand % 6]); + } + + let data = [data[0], data[1], data[2]]; + let mut guard = LockGuard::lock(&data, key); + *guard[0] += *guard[1]; + *guard[1] += *guard[2]; + *guard[2] += *guard[0]; + }); + } + + let key = ThreadKey::lock().unwrap(); + let data = LockGuard::lock(&DATA, key); + for val in &*data { + println!("{}", **val); + } +} |