问题挑战：如何在Java中实现线程同步？

原创拼搏现实的明天。 2024-12-05 06:33 13阅读 0赞

在Java中，有多种方式来实现线程同步。以下是其中几种常见的方法：

1. **synchronized关键字**：
   在方法声明或代码块前面使用`synchronized`关键字，可以实现同一时刻只有一个线程访问该资源。

```java
public class Counter {
    private int count;

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

public synchronized int getCount() {
        return count;
    }
}
```

2. **wait/notify**：
   通过`Object`类提供的`wait()`和`notify()`方法，可以实现线程间的同步。通常在一个对象上调用这两个方法，将线程的状态改变。

```java
public class SynchronizedExample {
    private Object lock = new Object();

public void thread1() {
        synchronized (lock) {  // 使用锁
            while (!isReady()) {  // 等待条件满足
                try:
                    lock.wait();  // 让出锁
                catch (InterruptedException e) {
                    Thread.currentThread().interrupt();
                }
            }

performTask();  // 执行任务
            notifyAll();  // 唤醒所有等待的线程
        }
    }

private boolean isReady() {  // 等待条件
        // 这里是示例，您可以根据实际情况设计逻辑
        return true;  // 假设已经准备好执行任务
    }

public void startThread1() {
        new Thread(thread1::run)).start();
    }
}
```

3. **Semaphore**：
   `Semaphore`是Java中用于控制共享资源的类。它通过初始量（可以为0）来限制并发访问的数量。

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

public class SemaphoreExample {
    private Semaphore semaphore = new Semaphore(1);  // 初始量为1

public void thread1() {
        try {
            semaphore.acquire();  // 请求锁
            performTask();  // 执行任务
            semaphore.release();  // 释放锁
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        }
    }

public void startThread1() {
        new Thread(thread1::run)).start();
    }
}
```

以上就是几种在Java中实现线程同步的方法。具体选择哪种方式，需要根据实际需求和系统架构来决定。