Java并发编程实战：条件变量使用示例

原创心已赠人 2024-11-21 05:21 4阅读 0赞

在Java的并发编程中，`ConditionVariable`是一种用于线程间通信的同步工具。当一个线程调用其等待方法（如wait()）时，它会将控制权释放到其他线程，并进入等待状态。

下面是一个简单的条件变量使用示例：

```java
import java.util.concurrent.Condition;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.TimeUnit;

public class ConditionVariableExample {

private final CountDownLatch signal = new CountDownLatch(1);
    private final Condition readyToWork = new ReadyToWork();

public void workerThread() throws InterruptedException {
        try {
            // 等待信号
            signal.await(1, TimeUnit.SECONDS));

// 检查是否准备好工作
            if (readyToWork.test()) {
                // 执行工作
                System.out.println("Worker is ready to work!");
            } else {
                System.out.println("Worker is not ready yet.");
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

public void signalThread() throws InterruptedException {
        // 发送信号，让worker线程开始工作
        signal.countDown();
    }

public static void main(String[] args) {
        ConditionVariableExample example = new ConditionVariableExample();

// 创建worker线程和signal线程
        new Thread(example::workerThread).start();
        new Thread(example::signalThread)).start();

try {
            // 等待所有线程完成
            example.signal.await(5, TimeUnit.SECONDS));
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }

}

// 条件变量类，用于检查是否准备好工作
class ReadyToWork implements Condition {

@Override
    public boolean test() throws Exception {
        // 这个方法可以模拟实际的准备工作条件
        return true; // 假设当前已经准备好工作了
    }

@Override
    public void wait() throws InterruptedException, BrokenQueueException {
        // 在这里可以添加线程阻塞等逻辑，以实现等待条件
        Thread.sleep(1000); // 假设这里需要睡眠一段时间
    }

@Override
    public void signal() {
        // 这个方法可以用来通知条件变量，触发唤醒操作
        // 在实际应用中，这通常是由一个独立线程或者事件驱动系统来调用的
    }
}
```

这个示例中，`workerThread`线程等待信号发出后进行工作检查。而`signalThread`线程负责发送信号给等待的工作者。当所有条件满足时，程序会正常执行。