Java的并发工具类：使用Lock和Condition的示例

原创红太狼 2024-11-27 08:36 21阅读 0赞

在Java中，`java.util.concurrent.locks.Lock` 和 `java.util.concurrent.locks.Condition` 是两个常用的并发工具类。它们分别用于锁定资源和控制线程的等待状态。

下面是一个使用`Lock`和`Condition`的简单示例：

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

class Producer {
    private final Lock lock = new ReentrantLock();
    private final Condition notFull = lock.newCondition();

private int product;

public void produce() {
        try {
            lock.acquire(); // 获取锁

while (product >= 0) { // 如果容器满
                notFull.await(); // 等待条件满足
                if (product < 0) { // 若产品已变负
                    break; // 结束循环，因为无法再生产
                }
            }

product++; // 生产一个产品

lock.notifyAll(); // 提醒所有等待的线程

} catch (InterruptedException e) {
            e.printStackTrace();
        } finally {
            lock.unlock(); // 释放锁
        }
    }
}

class Consumer {
    private final Lock lock = new ReentrantLock();
    private final Condition notEmpty = lock.newCondition();

public void consume() {
        try {
            lock.acquire(); // 获取锁

while (product <= 0) { // 如果容器空
                notEmpty.await(); // 等待条件满足
                if (product > 0) { // 若产品已变正
                    break; // 结束循环，因为无法再消费
                }
            }

product--; // 消费一个产品

lock.notifyAll(); // 提醒所有等待的线程

} catch (InterruptedException e) {
            e.printStackTrace();
        } finally {
            lock.unlock(); // 释放锁
        }
    }
}

public class Main {
    public static void main(String[] args) {
        Producer producer = new Producer();
        Consumer consumer = new Consumer();

new Thread(producer).start(); // 生产线程
        new Thread(consumer).start(); // 消费线程

try {
            producer.produce(); // 生产一个产品
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}
```

在这个例子中，`Producer` 生产产品，而 `Consumer` 消费产品。两者通过锁（Lock）和条件（Condition）来协调生产和消费的进度。