在Java多线程编程中的死锁问题实例

原创淡淡的烟草味﹌ 2024-11-30 22:42 25阅读 0赞

死锁是多线程编程中的一种严重问题，当两个或更多线程因争夺资源而造成的一种互相等待的现象时，就会发生死锁。

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

```java
// 线程1和2需要共享的资源（如一个计数器）
public class SharedResource {
    private int counter = 0;

public synchronized void increment() {
        counter++;
        notifyAll(); // 通知所有等待的线程
    }

public synchronized void decrement() {
        if (counter > 0) {
            counter--;
            notifyAll();
        }
    }

public int getCounter() {
        return counter;
    }
}

// 线程类，尝试增加和减少计数器
class ThreadExample extends Thread {
    private SharedResource resource;

public ThreadExample(SharedResource resource) {
        this.resource = resource;
    }

@Override
    public void run() {
        try {
            // 线程1（增加计数器）和2（减少计数器）交替执行
            Thread.sleep(500);  // 模拟线程的睡眠

if (resource.getCounter() > 0) {  // 如果计数器不为零
                resource.increment();  // 增加计数器
                System.out.println("Thread 1: Increment counter to " + resource.getCounter());

Thread.sleep(500);  // 模拟线程的睡眠

if (resource.getCounter() > 0) {  // 如果计数器不为零
                    resource.decrement();  // 减少计数器
                    System.out.println("Thread 2: Decrement counter to " + resource.getCounter());

Thread.sleep(500);  // 模拟线程的睡眠

if (resource.getCounter() == 0) {  // 如果计数器为零，表示已经完成死锁
                        System.out.println("Deadlock resolution: Counter reached zero, releasing resources.");
                        break;  // 结束当前循环
                    }
                }
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

public class Main {
    public static void main(String[] args) {
        SharedResource resource = new SharedResource();

ThreadExample thread1 = new ThreadExample(resource, "Increase counter"));
        ThreadExample thread2 = new ThreadExample(resource, "Decrement counter"));

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

try {
            // 等待所有线程执行完毕（如果发生死锁，这里会等待计数器为零）
            thread1.join();
            thread2.join();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

System.out.println("After all threads finished:");
        resource.printCurrentStatus();  // 输出当前资源状态
    }
}
```

在这个示例中，两个线程（Thread 1和Thread 2）分别尝试增加和减少共享的计数器。由于这两个线程都阻塞在他们的操作上（直到计数器达到0释放锁），这就形成了一个死锁。