#lock #mutex #rwlock #locking

padlock

Safely acquire RwLock/Mutex locks

3 unstable releases

0.2.0 May 4, 2020
0.1.1-alpha Feb 1, 2020
0.1.0-alpha Jan 28, 2020

#32 in #rwlock

Download history 477/week @ 2024-03-13 437/week @ 2024-03-20 352/week @ 2024-03-27 429/week @ 2024-04-03 451/week @ 2024-04-10 431/week @ 2024-04-17 466/week @ 2024-04-24 403/week @ 2024-05-01 333/week @ 2024-05-08 402/week @ 2024-05-15 453/week @ 2024-05-22 310/week @ 2024-05-29 338/week @ 2024-06-05 273/week @ 2024-06-12 295/week @ 2024-06-19 270/week @ 2024-06-26

1,230 downloads per month
Used in 5 crates (via tray-item)

MIT/Apache

9KB
96 lines

Padlock

Safely acquire RwLock/Mutex locks and never worry about remembering to drop them!

CircleCI docs

License

MIT or Apache-2.0


lib.rs:

Aquire Mutex and RwLocks safely.

All methods in this crate will try to lock the passed Mutex or RwLock, if the locking fails, spin_loop_hint is called and we try again. This practice is called spinlock.

This means that all calls will block the current thread.

Important: When using methods like mutex_lock, remember that the lock is droped first when the lambda finishes running.

Example:

 use std::{
     thread,
     sync::{Arc, Mutex},
     time::Duration
 };

 #[derive(Debug)]
 struct Person {
     age: u8,
     name: String
 }

 fn main() {

     let people = Arc::new(Mutex::new(Vec::<Person>::new()));
     let mut threads = Vec::<thread::JoinHandle<()>>::new();

     // Write in one thread
     let people_clone = Arc::clone(&people);
     threads.push(thread::spawn(move || {

         for i in 0..10 {

             padlock::mutex_lock(&people_clone, |lock| {

                 lock.push(Person {
                     age: i * 10,
                     name: format!("Name {}", i)
                 });

             });

             thread::sleep(Duration::from_millis(500));

         }

     }));

     // Read from another
     let people_clone = Arc::clone(&people);
     threads.push(thread::spawn(move || {

         for _ in 0..6 {

             padlock::mutex_lock(&people_clone, |lock| {

                 for person in lock {
                     println!("{:?}", person);
                 }

             });

             thread::sleep(Duration::from_secs(1));

         }

     }));

     for t in threads {
         t.join();
     }

 }

No runtime deps