Java多线程：等待和条件变量示例

原创﹏ヽ暗。殇╰゛Y 2024-12-04 21:51 27阅读 0赞

在Java中，多线程提供了并发执行的机制。当涉及到线程间的通信时，`wait()`、`notify()`和`ConditionVariable`等概念就显得尤为重要。

以下是一个使用`wait()`、`notify()`和`ConditionVariable`的简单示例：

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

public class WaitAndNotifyExample {

private Lock lock = new ReentrantLock();
    private Condition condition = lock.newCondition();

public void threadA() {
        try {
            lock.lock();

// 表示线程A需要进行一些操作
            System.out.println("Thread A: Operation in progress...");

// 等待条件满足，即另一个线程通知了条件
            condition.await();

// 表示线程A完成操作后释放锁
            lock.unlock();
        } catch (InterruptedException e) {
            // 处理中断异常
            System.out.println("Thread A: Interrupted while waiting.");
            e.printStackTrace();
        }
    }

public void threadB() {
        try {
            lock.lock();

// 表示线程B需要通知条件变量，唤醒等待的线程A
            System.out.println("Thread B: Notifying condition for wake up...");
            condition.notifyAll();

// 表示线程B完成操作后释放锁
            lock.unlock();
        } catch (InterruptedException e) {
            // 处理中断异常
            System.out.println("Thread B: Interrupted while notifying.");
            e.printStackTrace();
        }
    }

public static void main(String[] args) {

WaitAndNotifyExample example = new WaitAndNotifyExample();

Thread threadA = new Thread(example::threadA));
        Thread threadB = new Thread(example::threadB));

// 启动线程
        threadA.start();
        threadB.start();
    }
}
```

这个示例中，`ThreadA`等待条件满足后才会进行操作，而`ThreadB`则负责唤醒等待的线程。