Java并发编程：条件变量使用示例解析

原创 ╰+攻爆jí腚メ 2024-12-07 22:09 6阅读 0赞

在Java的并发编程中，条件变量（Condition Variable）是一种用于同步的机制，它主要由三个部分组成：wait()、notify()和notifyAll()。

以下是一个简单的使用条件变量的例子：

```java
import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;

public class ConditionVariableExample {
    private Lock lock = new ReentrantLock();
    private Condition notReady = lock.newCondition("Not Ready");
    private Condition ready = lock.newCondition("Ready");

public void waitForReady() throws InterruptedException {
        lock.lock();
        try {
            while (!ready.await(1, TimeUnit.SECONDS))) {
                // 线程等待条件满足
            }
            System.out.println("The thread is now ready.");
        } finally {
            lock.unlock();
        }
    }

public void signalReady() {
        lock.lock();
        try {
            ready.signalAll();
        } finally {
            lock.unlock();
        }
    }

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

// 创建一个线程，等待条件ready
        Thread waiterThread = new Thread(() -> {
            try {
                example.waitForReady();
                System.out.println("The waiter thread woke up.");
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }));

// 创建另一个线程，准备条件ready
        Thread preparerThread = new Thread(() -> {
            try {
                example.signalReady();
                System.out.println("The preparer thread woke up to signal ready.");
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }));

waiterThread.start();
        preparerThread.start();

// 等待准备者线程唤醒
        preparerThread.join();
    }
}
```

在这个例子中，`waitForReady()` 方法的线程会等待`ready`条件变量被信号。而`signalReady()`方法的线程则会在准备好的情况下通知所有等待的线程。

通过这样的条件变量使用，我们可以实现更复杂的并发场景控制。