实战：Java多线程同步问题实例

原创太过爱你忘了你带给我的痛 2024-11-23 15:45 14阅读 0赞

在Java编程中，多线程同步是非常重要的一环，它确保了多个线程对共享资源的访问是协调的。以下是一个具体的实例：

**问题描述：**
假设有一个类`MyClass`，其中包含一个全局变量`sharedData`，并且有多个方法需要修改这个数据。

**解决方案：**
1. **锁（Lock）**：
   使用`java.util.concurrent.locks.Lock`进行同步。例如，使用`ReentrantLock`：

```java
   private final Lock lock = new ReentrantLock();

public void modifySharedData() {
       lock.lock(); // 获取锁
       try {
           // 修改 sharedData
           // ...
       } finally {
           lock.unlock(); // 释放锁
       }
   }
   ```

2. **条件变量（Condition Variable）**：
   当需要等待某个特定的事件发生时，可以使用`java.util.concurrent.Condition`。例如：

```java
   private final Condition ready = new Condition() {
       @Override
       public boolean isReady() {
           // 确保只有在满足特定条件时，才会触发准备
           // ...
           return true; // 通常返回true表示准备就绪
       }

@Override
       public void await(long timeout, TimeUnit unit)) throws InterruptedException {
           if (timeout > 0) {
               try {
                   // 如果需要等待一定时间，则会在此超时时间内阻塞，直到条件满足
                   Thread.sleep(unit.toMillis(timeout)));
                   } catch (InterruptedException e) {
                       throw e; // 抛出原异常
                   }
               }
           }

@Override
           public void signal() {
               // 在这里触发信号以唤醒等待的线程
               // ...
           }
       };

private final Lock lock = new ReentrantLock();

public void modifySharedDataWhenReady() {
       lock.lock(); // 获取锁
       try {
           // 监听 ready 事件
           ready.addListener(new ConditionListener() {
               @Override
               public void conditionMet() {
                   // 当条件满足（例如当共享数据准备好修改时）时，执行修改操作
                   modifySharedData();
               }
           }));

// 等待 ready 事件发生
           ready.await(); // 睡眠，直到 ready 触发
       } finally {
           lock.unlock(); // 释放锁
       }
   }
   ```

通过以上实例，我们可以看到在多线程环境下，如何使用锁和条件变量来实现同步控制。