Java多线程同步问题：wait()和notify()的使用示例

原创太过爱你忘了你带给我的痛 2024-09-29 22:57 53阅读 0赞

在Java多线程编程中，wait()和notify()是两个关键的方法，用于线程之间的同步。

1. wait()方法：
   - 在synchronized块或方法内部调用。
   - 调用后，线程会立即释放对象锁，进入等待状态（block）。

2. notify()方法：
   - 通常在同一个对象的synchronized块或方法中使用。
   - 主要用于唤醒之前处于wait状态的线程。

示例：

```java
// 定义一个共享对象
class Counter {
    int count = 0;

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

synchronized int decrement() {
        if (count > 0) {
            count--;
            notifyAll();
            return count; // 返回新的计数值
        } else {
            throw new IllegalArgumentException("Counter is already at zero!");
        }
    }
}

public class WaitNotifyExample {
    public static void main(String[] args) {
        // 创建一个共享对象
        Counter counter = new Counter();

// 创建两个线程，分别执行增加和减少操作
        Thread incrementThread = new Thread(() -> {
            while (true) { // 无限循环，等待通知
                try {
                    counter.increment(); // 增加计数
                    System.out.println("Increment thread: Count " + counter.count);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        }));

Thread decrementThread = new Thread(() -> {
            while (true) { // 无限循环，等待通知
                try {
                    counter.decrement(); // 减少计数
                    System.out.println("Decrement thread: Count " + counter.count);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        }));

incrementThread.start();
        decrementThread.start();

// 等待主线程结束，防止资源泄露
        try {
            Thread.currentThread().join(); // Java 8及以上版本使用此方法等待线程完成
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

System.out.println("Counter count after threads: " + counter.count);
    }
}
```

在这个示例中，创建了两个线程，一个用于增加计数，另一个用于减少计数。通过synchronized关键字确保了对共享资源的正确同步。在主线程结束后，打印出最终的计数值。