Java多线程编程：常见死锁实例

原创偏执的太偏执、 2024-11-30 11:06 26阅读 0赞

在Java多线程编程中，死锁是一种常见的并发问题。当两个或更多的线程相互等待对方释放资源时，就会形成死锁。

以下是一些常见的死锁实例，使用了Java的ExecutorService来模拟多线程环境：

1. **循环等待资源**：
   ```java
   // 线程1等待线程2释放资源A
   Thread t1 = new Thread(() -> {
       ResourceA a = new ResourceA();
       while (!t2.hasResource(a)) {
           System.out.println("Thread 1 waiting for resource A...");
           try {
               // 等待
               Thread.sleep(1000);
           } catch (InterruptedException e) {
               e.printStackTrace();
           }
       }
       System.out.println("Thread 1 received resource A from Thread 2.");
   }));

// 线程2等待线程1释放资源B
   Thread t2 = new Thread(() -> {
       ResourceB b = new ResourceB();
       while (!t1.hasResource(b)) {
           System.out.println("Thread 2 waiting for resource B...");
           try {
               // 等待
               Thread.sleep(1000);
           } catch (InterruptedException e) {
               e.printStackTrace();
           }
       }
       System.out.println("Thread 2 received resource B from Thread 1.");
   }));

t1.start();
   t2.start();

// 此处需要保证线程2在资源B被释放后才能启动线程1
   // 假设线程2等待的事件触发了，那么可以执行以下操作：
   // t2.notify(); // 将线程唤醒
   // if (t1.isAlive()) { // 检查线程1是否还在运行
   //     System.out.println("Resuming Thread 1 as resource B has been released.");
   //     t1.interrupt(); // 中断线程1的执行
   // } else { // 如果线程1已经结束，我们可以直接进行资源的获取
   //     System.out.println("Thread 1 no longer exists. Fetching resource B directly.");
   //     ResourceB b = new ResourceB();
   //     t2.hasResource(b); // 检查线程2是否拥有资源B
   //     if (b != null) { // 如果资源B存在，进行获取操作
   //         System.out.println("Thread 1 successfully fetched resource B.");
   //         // 这里可以进行资源的使用逻辑
   //         // ...
   //       } else {
   //           System.out.println("Resource B not found by Thread 2. Deadlock detected.");
   //       }
   //     }
   // }
   ```

2. **循环获取资源**：
   ```java
   // 线程1等待线程2释放资源A
   Thread t1 = new Thread(() -> {
       ResourceA a = new ResourceA();
       while (!t2.hasResource(a)) {
           System.out.println("Thread 1 waiting for resource A...");
           try {
               // 等待
               Thread.sleep(1000);
           } catch (InterruptedException e) {
               e.printStackTrace();
           }
       }
       System.out.println("Thread 1 received resource A from Thread 2.");
   }));

t1.start();
   t2.start();

这些实例展示了线程死锁的一些常见场景。在实际编程中，需要充分理解并发原理，避免设计出可能导致死锁的并发控制结构。