并发编程中的死锁理解误区：Java多线程实现示例

原创本是古典何须时尚 2024-09-17 16:48 61阅读 0赞

在并发编程中，"死锁"是一个常见的理解和处理误区。以下是对此的误解以及一个简单的Java多线程实现示例：

**误解1：**
**所有人都等待资源，而这些资源被其他线程占用。**

这种理解是正确的。当两个或更多的线程互相等待对方释放资源时，就可能发生死锁。

**示例：**
以下是一个简单的Java多线程死锁示例：

```java
// 定义共享资源
class Resource {
    private int count;

public Resource(int initialCount) {
        this.count = initialCount;
    }

// 增加资源
    public synchronized void acquire() {
        if (count <= 0) { // 线程等待资源
            System.out.println("Thread " + Thread.currentThread().getName() + " is waiting for resource ...");
            count = 1; // 资源被占用，但状态未改变
            notifyAll(); // 通知等待的线程
        } else {
            count++; // 资源增加
        }
    }

// 减少资源
    public synchronized void release() {
        if (count > 0) { // 如果资源存在
            count--; // 资源减少
            notifyAll(); // 通知等待的线程
        } else { // 如果资源已经耗尽
            System.out.println("Thread " + Thread.currentThread().getName() + " is trying to release an already exhausted resource ...");
        }
    }
}

// 主线程，尝试获取和释放资源
public class Main {
    private Resource resource;

public Main(Resource resource) {
        this.resource = resource;
    }

public void startThreads() {
        // 线程1：获取资源
        Thread thread1 = new Thread(() -> {
            System.out.println("Thread 1: Acquiring resource ...");
            resource.acquire(); // 获取资源
        }));

// 线程2：释放资源
        Thread thread2 = new Thread(() -> {
            System.out.println("Thread 2: Releasing resource ...");
            resource.release(); // 释放资源
        }));

// 启动线程
        thread1.start();
        thread2.start();
    }

public static void main(String[] args) {
        Resource resource = new Resource(5); // 创建资源，初始数量为5

Main main = new Main(resource); // 创建主类实例

try {
            main.startThreads(); // 启动线程
            Thread.sleep(1000); // 线程睡眠一段时间（防止主线程过早退出）
        } catch (InterruptedException e) {
            System.out.println("Thread sleep interrupted ...");
            e.printStackTrace();
        }

// 输出释放资源后的状态
        resource.printCount(); // 调用打印当前资源数量的方法
    }
}
```

在这个示例中，我们创建了一个`Resource`类，它有获取和释放资源的公共方法。主线程启动两个线程分别尝试获取和释放资源，最终输出资源的状态。