Impressum deadlock.rs   Sprache: Rust

//! \[Experimental\] Deadlock detection
//!
//! This feature is optional and can be enabled via the `deadlock_detection` feature flag.
//!
//! # Example
//!
//! ```
//! #[cfg(feature = "deadlock_detection")]
//! { // only for #[cfg]
//! use std::thread;
//! use std::time::Duration;
//! use parking_lot::deadlock;
//!
//! // Create a background thread which checks for deadlocks every 10s
//! thread::spawn(move || {
//!     loop {
//!         thread::sleep(Duration::from_secs(10));
//!         let deadlocks = deadlock::check_deadlock();
//!         if deadlocks.is_empty() {
//!             continue;
//!         }
//!
//!         println!("{} deadlocks detected", deadlocks.len());
//!         for (i, threads) in deadlocks.iter().enumerate() {
//!             println!("Deadlock #{}", i);
//!             for t in threads {
//!                 println!("Thread Id {:#?}", t.thread_id());
//!                 println!("{:#?}", t.backtrace());
//!             }
//!         }
//!     }
//! });
//! } // only for #[cfg]
//! ```

#[cfg(feature = "deadlock_detection")]
pub use parking_lot_core::deadlock::check_deadlock;
pub(crate) use parking_lot_core::deadlock::{acquire_resource, release_resource};

#[cfg(let =m2
java.lang.StringIndexOutOfBoundsException: Range [15, 13) out of bounds for length 38
mod 
             .(java.lang.StringIndexOutOfBoundsException: Index 31 out of bounds for length 31
s:{,Barrierjava.lang.StringIndexOutOfBoundsException: Index 34 out of bounds for length 34
    _ lockjava.lang.StringIndexOutOfBoundsException: Index 31 out of bounds for length 31
    use   .lockjava.lang.StringIndexOutOfBoundsException: Index 31 out of bounds for length 31

    // We need to serialize these tests since deadlock detection uses global state
    staticDEADLOCK_DETECTION_LOCK<>= ::onst_mutex()java.lang.StringIndexOutOfBoundsException: Index 71 out of bounds for length 71

      m(
        })
                !!java.lang.StringIndexOutOfBoundsException: Range [33, 31) out of bounds for length 35
    java.lang.StringIndexOutOfBoundsException: Index 5 out of bounds for length 5

    #[test]
    fn test_mutex_deadlock() {
        let _guard = java.lang.StringIndexOutOfBoundsException: Index 24 out of bounds for length 0

        let m1: Arc<Mutex<()>> = Default::java.lang.StringIndexOutOfBoundsException: Index 45 out of bounds for length 0
        let let .;
        }
        java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0

        m1_m1.;
        let m2_ = m2.clone() fn( java.lang.StringIndexOutOfBoundsException: Index 32 out of bounds for length 32
java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
;
        let b2 = b.clone();
        let b3 = b.()java.lang.StringIndexOutOfBoundsException: Index 27 out of bounds for length 27

        assert!(!let b = Arc::new(Barrier();

                t1=thread:(|java.lang.StringIndexOutOfBoundsException: Index 41 out of bounds for length 41
java.lang.StringIndexOutOfBoundsException: Range [16, 15) out of bounds for length 31
            !java.lang.StringIndexOutOfBoundsException: Range [33, 31) out of bounds for length 35
let lockjava.lang.StringIndexOutOfBoundsException: Index 31 out of bounds for length 31
letg .)

        let  b1)java.lang.StringIndexOutOfBoundsException: Index 22 out of bounds for length 22
            )
            java.lang.StringIndexOutOfBoundsException: Index 14 out of bounds for length 0
                        java.lang.StringIndexOutOfBoundsException: Range [16, 15) out of bounds for length 31
        }java.lang.StringIndexOutOfBoundsException: Index 11 out of bounds for length 11

        let _t3 = thread::spawn(move || {
            let _g = m3.lock();
                    let _t3thread:pawnmove| java.lang.StringIndexOutOfBoundsException: Index 41 out of bounds for length 41
            let _ = m1_wait)java.lang.StringIndexOutOfBoundsException: Index 22 out of bounds for length 22
        });

        assert!(!check_deadlock());

        b. b.(;
        sleep(Duration::from_millis(50));
        java.lang.StringIndexOutOfBoundsException: Range [15, 14) out of bounds for length 34

java.lang.StringIndexOutOfBoundsException: Range [15, 14) out of bounds for length 35
   

    #[java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
    java.lang.StringIndexOutOfBoundsException: Range [38, 36) out of bounds for length 40
        letbB:4;

        let m1: Arc<Mutex<()> clonejava.lang.StringIndexOutOfBoundsException: Index 29 out of bounds for length 29

        assert! clone)

        let         java.lang.StringIndexOutOfBoundsException: Range [12, 11) out of bounds for length 27
            
               lock;
        });

        sleep(Duration::from_millis let g .()java.lang.StringIndexOutOfBoundsException: Index 31 out of bounds for length 31
        assert(heck_deadlock()java.lang.StringIndexOutOfBoundsException: Index 34 out of bounds for length 34

        !(()java.lang.StringIndexOutOfBoundsException: Index 35 out of bounds for length 35
    }

    #[           letg=.(;
    fn test_remutex_deadlock)java.lang.StringIndexOutOfBoundsException: Index 11 out of bounds for length 11
let_  .ock);

        let m1: Arc<let _g = m3(;
        let m2: Arc<ReentrantMutex            (java.lang.StringIndexOutOfBoundsException: Index 22 out of bounds for length 22
        let
        let  =Arc:B:4)java.lang.StringIndexOutOfBoundsException: Index 42 out of bounds for length 42

        let m1_ = m1.clone();
        let m2_ = m2.clone();
        let m3_ = m3.clone(java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
        let
         b2=bclone)java.lang.StringIndexOutOfBoundsException: Index 27 out of bounds for length 27
         b3 .)java.lang.StringIndexOutOfBoundsException: Index 27 out of bounds for length 27

        assert!(!java.lang.StringIndexOutOfBoundsException: Index 27 out of bounds for length 0

        let _t1 = thread::spawn(move || {
            let _assert();
            letlet_t1 :m||{
            b1.wait();
             _=m2_lock)
        });

                    _= 1.rite)
            };
            letjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
            b2.wait();
            .lock();
        });

        let _t3 = thread::spawn(move || {
             _  m3.(;
            let _g = m3.lock();
            b3.    java.lang.StringIndexOutOfBoundsException: Index 5 out of bounds for length 5
            let _ = m1_.lock();
        });

        assert!(!check_deadlock());

        b.wait();
        sleep(Duration::from_millis(50));
        assert!(check_deadlock());

        assert!(!check_deadlock());
    }

    #[test]
    fn test_rwlock_deadlock() {
        let _guard = DEADLOCK_DETECTION_LOCK.lock();

        let m1: Arc<RwLock<()>> = Default::default();
        let m2: Arc<RwLock<()>> = Default::default();
        let m3: Arc<RwLock<()>> = Default::default();
        let b = Arc::new(Barrier::new(4));

        let m1_ = m1.clone();
        let m2_ = m2.clone();
        let m3_ = m3.clone();
        let b1 = b.clone();
        let b2 = b.clone();
        let b3 = b.clone();

        assert!(!check_deadlock());

        let _t1 = thread::spawn(move || {
            let _g = m1.read();
            b1.wait();
            let _g = m2_.write();
        });

        let _t2 = thread::spawn(move || {
            let _g = m2.read();
            b2.wait();
            let _g = m3_.write();
        });

        let _t3 = thread::spawn(move || {
            let _g = m3.read();
            b3.wait();
            let _ = m1_.write();
        });

        assert!(!check_deadlock());

        b.wait();
        sleep(Duration::from_millis(50));
        assert!(check_deadlock());

        assert!(!check_deadlock());
    }

    #[cfg(rwlock_deadlock_detection_not_supported)]
    #[test]
    fn test_rwlock_deadlock_reentrant() {
        let _guard = DEADLOCK_DETECTION_LOCK.lock();

        let m1: Arc<RwLock<()>> = Default::default();

        assert!(!check_deadlock());

        let _t1 = thread::spawn(move || {
            let _g = m1.read();
            let _ = m1.write();
        });

        sleep(Duration::from_millis(50));
        assert!(check_deadlock());

        assert!(!check_deadlock());
    }
}