Java多线程同步问题：原子操作及wait/notify示例

原创红太狼 2024-09-10 17:27 56阅读 0赞

在Java多线程中，理解和使用原子操作以及`wait/notify`机制是非常重要的。这里我们将分别介绍这两个概念。

1. 原子操作：
   - Java中的原子操作主要通过`AtomicInteger`, `AtomicLong`, `AtomicReference`等类实现。
   - 原子操作的特点是无论其他线程如何修改，对原子变量的操作要么全部完成，要么全部失败回滚。这样保证了数据的一致性。

2. `wait/notify`示例：
   - 这个机制主要用于线程之间的通信，主要应用于无限循环或者条件满足后需要其他线程知道的情况。
   - 示例代码如下：

```java
// 假设我们有一个共享资源count
public class Counter {
    private int count;

// 初始化计数器
    public Counter(int count) {
        this.count = count;
    }

// 原子增加计数器
    public synchronized void increment() {
        count++;
    }

// 获取当前的计数器值
    public synchronized int getCount() {
        return count;
    }
}

// 多线程示例，两个线程交替更新计数器
public class CounterThreadExample {
    private static final int THREAD_COUNT = 2;
    private static final int COUNT_START = 10;

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

// 创建并启动多个线程
        Thread thread1 = new Thread(() -> {
            while (true) {
                try {
                    // 原子增加计数器
                    counter.increment();
                    System.out.println("Thread 1: Count " + counter.getCount());
                } catch (InterruptedException e) {
                    e.printStackTrace();
                    break;
                }
            }
        }));

Thread thread2 = new Thread(() -> {
            while (true) {
                try {
                    // 原子增加计数器
                    counter.increment();
                    System.out.println("Thread 2: Count " + counter.getCount());
                } catch (InterruptedException e) {
                    e.printStackTrace();
                    break;
                }
            }
        }));

// 启动线程
        thread1.start();
        thread2.start();

// 等待所有线程结束
        thread1.join();
        thread2.join();
    }
}
```

在这个例子中，两个线程交替执行原子增加计数器的操作。`wait/notify`机制用于线程间的通信，当一个线程调用`wait()`方法时会进入等待状态，而其他线程可以通过调用`notify()`或`notifyAll()`方法来唤醒它。

请注意，这个示例只是为了说明`wait/notify`在多线程同步中的应用。实际使用中可能需要根据具体需求进行修改和扩展。