同步问题：Java多线程并发中锁机制的实例分析

原创「爱情、让人受尽委屈。」 2024-09-18 17:00 63阅读 0赞

在Java多线程并发编程中，锁机制是一种关键控制手段，用于防止多个线程同时访问共享资源导致数据不一致或竞态条件等问题。

以下是一个简单的锁机制实例分析：

1. **共享资源**：例如一个计数器，初始化值为0。

```java
public class Counter {
    private int count = 0; // 共享资源

public synchronized void increment() {
        count++;
        notifyAll(); // 唤醒等待的线程
    }

public synchronized int decrement() {
        if (count > 0) { // 防止负数计数
            count--;
            if (count == 0) { // 如果计数为零，唤醒所有等待的线程
                notifyAll();
            }
        }
        return count;
    }
}
```

2. **多线程并发**：创建两个线程，分别调用`increment()`和`decrement()`方法。

```java
public class ThreadExample {
    public static void main(String[] args) {
        Counter counter = new Counter();
        Thread incrementThread = new Thread(() -> {
            while (true) { // 无限循环，确保线程始终运行在尝试增加计数器的阶段
                counter.increment();
                if (counter.getCount() >= 10) {
                    break; // 当计数器达到或超过10时，跳出循环
                }
            }
        }));
        Thread decrementThread = new Thread(() -> {
            while (true) { // 无限循环，确保线程始终运行在尝试减少计数器的阶段
                counter.decrement();
                if (counter.getCount() <= -5) {
                    break; // 当计数器达到或超过-5时，跳出循环
                }
            }
        }));

incrementThread.start(); // 启动增加计数器的线程
        decrementThread.start(); // 启动减少计数器的线程

try {
            incrementThread.join(); // 等待增加计数器的线程执行完毕
            decrementThread.join(); // 等待减少计数器的线程执行完毕
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

System.out.println("Final count: " + counter.getCount()); // 输出最终计数结果
    }
}
```

通过这个实例，你可以看到如何在Java中使用锁机制来管理共享资源并防止竞态条件。