理解和避免Java线程同步问题示例

原创柔情只为你懂 2024-10-08 02:18 67阅读 0赞

Java的线程同步问题是多方面的，主要是通过共享资源导致的竞争条件、死锁等问题。以下是一个简单的示例：

```java
// 假设我们有一个计数器类
public class Counter {
    private int count = 0;

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

public synchronized int decrement() {
        if (count > 0) {
            count--;
            notifyAll(); // 同理，向所有等待的线程发出通知
        }
        return count;
    }
}

// 测试类
public class ThreadSynchronizationExample {
    private Counter counter;

public ThreadSynchronizationExample() {
        counter = new Counter();
    }

public void thread1Increment() {
        while (counter.decrement() != 0) { // 确保计数器减到0
            try {
                // 模拟耗时操作
                Thread.sleep(100);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }

public void thread2Increment() {
        while (!counter.increment()) { // 确保计数器加到1
            try {
                // 模拟耗时操作
                Thread.sleep(50);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }

public void startThreads() {
        new Thread(() -> thread2Increment())).start();
        new Thread(() -> thread1Increment())).start();
    }

public static void main(String[] args) {
        ThreadSynchronizationExample example = new ThreadSynchronizationExample();
        example.startThreads();
    }
}
```

在这个示例中，我们有两个线程（thread1和thread2）分别操作一个计数器。问题在于，两个线程可能会同时进入`increment()`或`decrement()`方法，导致数据不一致。

要避免这种情况，我们需要使用Java的synchronized关键字或者ReentrantLock来控制对共享资源的访问。在这个示例中，我们通过synchronized修饰了Counter类的方法，保证了线程同步。