Java多线程同步问题实践案例

原创我不是女神ヾ 2024-09-16 03:54 65阅读 0赞

在Java中，多线程同步是为了保证多个线程访问共享资源时不会产生冲突或数据不一致。以下是一些实践案例：

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

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

public synchronized int getCount() {
        return count;
    }
}
```
在这个例子中，`increment()`和`getCount()`方法都被声明为synchronized，保证了在同一时间只有一个线程可以访问这些方法。

2. **wait/notify**：
```java
public class WaitNotify {
    private boolean flag = false;
    private int count = 0;

public synchronized void setFlag() {
        if (!flag) {
            flag = true;
            notifyAll(); // 通知所有等待的线程
        }
    }

public synchronized void increaseCount() {
        count++;
        if (count == 10) { // 当计数达到10时，执行下面的操作
            setFlag(); // 设置flag标志为true，然后调用notifyAll()
            count = 0; // 清零计数器
        }
    }

public synchronized int getCount() {
        return count;
    }
}
```
在这个例子中，`setFlag()`方法会改变一个共享的旗子标志。当旗子被设为真时，会调用`notifyAll()`通知所有等待的线程。

3. **使用Semaphore**：
Semaphore是Java中的一个同步工具，它能够控制同时访问特定资源的数量。

```java
import java.util.concurrent.Semaphore;

public class SemaphoreExample {
    private Semaphore semaphore = new Semaphore(1); // 创建一个允许一次通过的信号量

public synchronized void increment() throws InterruptedException {
        semaphore.acquire(); // 获取信号量，表示只有一个线程可以执行下面的操作
        incrementCount(); // 原先的方法
        semaphore.release(); // 释放信号量，表示该线程已经完成操作
    }

private synchronized void increaseCount() {
        count++;
        if (count == 10) { // 当计数达到10时，执行下面的操作
            setFlag(); // 设置flag标志为true，然后调用notifyAll()
            count = 0; // 清零计数器
        }
    }

public synchronized int getCount() {
        return count;
    }
}
```
在这个例子中，`increment()`方法会先获取信号量，表示只有一个线程可以执行下面的操作。当操作完成并释放信号量后，其他等待的线程就可以继续了。