理解并避免Java多线程同步问题实例

原创偏执的太偏执、 2024-09-16 06:04 92阅读 0赞

Java多线程同步问题是由于多个线程同时访问和修改共享资源而导致数据不一致的问题。下面提供一个简单的实例来帮助理解和避免这种情况。

**场景：**
- 有一个全局变量 `counter`，用于记录某个操作的次数。
- 定义两个线程，分别执行增加和减少计数器的操作。

**代码示例：**
```java
public class CounterSyncExample {
    private int counter = 0;

public void incrementCounter() {
        synchronized (this) { // 使用synchronized进行同步
            if (counter < Integer.MAX_VALUE) {
                counter++;
            }
        }
    }

public void decrementCounter() {
        synchronized (this) {
            if (counter > 0) {
                counter--;
            }
        }
    }

public static void main(String[] args) {
        CounterSyncExample counter = new CounterSyncExample();

// 创建线程
        Thread incrementThread = new Thread(() -> {
            for (int i = 1; i <= 5; i++) { // 每次增加5
                counter.incrementCounter();
            }
        }));

Thread decrementThread = new Thread(() -> {
            for (int i = 5; i >= 1; i--) { // 每次减少5
                counter.decrementCounter();
            }
        }));

// 启动线程
        incrementThread.start();
        decrementThread.start();

// 等待所有线程完成
        try {
            incrementThread.join();
            decrementThread.join();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

System.out.println("Final counter value: " + counter.counter);
    }
}
```

在这个例子中，`incrementCounter` 和 `decrementCounter` 线程分别增加和减少计数器。但由于没有正确同步这些操作，可能会导致计数器值不准确。

为避免这种情况，你应该使用Java的synchronized关键字或者java.util.concurrent包中的锁（如ReentrantLock）来确保同一时刻只有一个线程访问共享资源。