并发编程困惑：Java多线程同步问题示例

原创迷南。 2024-12-12 10:27 12阅读 0赞

在Java中，多线程的同步主要通过以下几种方式来实现：

1. **synchronized关键字**：
```java
public class Counter {
    private int count = 0;

public synchronized void increment() {
        count++;
    }

public synchronized int decrement() {
        if (count > 0) {
            count--;
            return count;
        } else {
            throw new RuntimeException("Counter is already at zero!");
        }
    }

public int getCount() {
        return count;
    }
}
```
2. **wait()和notify()方法**：
```java
public class WaitNotifyExample {
    private boolean flag = false;

public synchronized void changeFlag() {
        if (!flag) {
            flag = true;
            notifyAll();
        } else {
            try {
                wait();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }

public static void main(String[] args) {
        WaitNotifyExample example = new WaitNotifyExample();

new Thread(() -> {
            for (int i = 0; i < 10; i++) {
                example.changeFlag();
                System.out.println("Flag changed to " + flag);
            }
        })).start();

// 这里创建另一个线程，只是为了演示wait()和notify()
        new Thread(() -> {
            try {
                while (!flag) {
                    System.out.println("Waiting for flag change...");
                    wait();
                }

System.out.println("Flag is set, notifying other threads...");
                notifyAll();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        })).start();
    }
}
```
3. **原子类和原子方法**：
Java 8引入了`java.util.concurrent.atomic包`，其中包含一些原子操作。

例如，使用AtomicInteger作为共享计数器：

```java
import java.util.concurrent.atomic.AtomicInteger;

public class AtomicExample {
    private AtomicInteger count = new AtomicInteger(0);

public void increment() {
        count.incrementAndGet();
    }

public int decrementIfPositive() {
        if (count.getAndDec() > 0) {
            return count.get();
        } else {
            throw new RuntimeException("Counter value is already zero!");
        }
    }

public int getCount() {
        return count.get();
    }
}
```
以上示例展示了Java多线程同步问题的解决方式。在实际项目中，还需要根据具体需求选择合适的同步机制。