理解和解决Java多线程同步问题的实例

原创梦里梦外; 2024-10-16 21:15 52阅读 0赞

Java多线程同步问题主要是为了避免多个线程同时访问和修改共享资源导致的数据不一致。以下是理解并解决这种问题的一个实例：

**问题描述：**
假设有一个计数器类`Counter`，它有两个共享变量`count`和`lock`。

```java
class Counter {
    private int count;
    private Object lock;

// getters and setters
}
```

**同步问题：**
多个线程同时访问`incrementCount()`方法可能会导致`count`不正确。

```java
public class ThreadExample {
    private final Counter counter;

public ThreadExample(Counter counter) {
        this.counter = counter;
    }

public void startThreads() {
        // 创建并启动两个线程
        Thread thread1 = new Thread(() -> incrementCountThread1()));
        Thread thread2 = new Thread(() -> incrementCountThread2()));

thread1.start();
        thread2.start();
    }

private void incrementCountThread1() {
        while (true) { // 无限循环，模拟长时间访问
            synchronized (counter.getLock()) { // 使用锁同步
                if (counter.getCount() < 5) { // 如果计数器小于5，增加一次
                    counter.incrementCount();
                }
            }
        }
    }

private void incrementCountThread2() {
        while (true) {
            // 这里不需要同步，因为每次循环后，计数器会被修改回正确的值
            if (counter.getCount() >= 5) { // 如果计数器大于等于5，减少一次
                counter.decrementCount();
            }
        }
    }
}
```

在这个例子中，通过使用锁（`Object lock;`）来同步对共享资源的访问。这样就确保了任何时候只有一个线程能够修改`count`。

当两个线程同时执行`incrementCountThread1()`时，由于锁的存在，它们会相互等待，直到获得锁后才继续执行。这样就可以避免数据不一致的情况。