Java并发控制：Lock和Condition的对比应用示例

原创 Bertha 。 2024-12-10 18:21 30阅读 0赞

在Java中，Lock接口提供了比同步器更细粒度的控制，而Condition抽象类则是在锁的基础上提供了一个线程等待/唤醒的地方。

以下是一些对比应用示例：

1. 锁：比如使用ReentrantLock，当一个线程获取到锁后，其他尝试获取该锁的线程将被阻塞。

示例代码：
```java
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;

public class LockExample {
    private final Lock lock = new ReentrantLock();

public void acquire() {
        try {
            lock.lock();
            System.out.println("Lock acquired");
        } catch (InterruptedException e) {
            e.printStackTrace();
        } finally {
            // 无论是否捕获异常，都要释放锁
            try {
                lock.unlock();
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    }

public void release() {
        lock.unlock();
    }

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

// 获取锁
        example.acquire();

// 线程执行其他任务
        Thread.sleep(2000); // 休眠2秒

// 释放锁
        example.release();
    }
}
```
在这个例子中，`acquire()`方法用于获取锁，`release()`方法用于释放锁。

2. Condition：在获得锁后，可以通过Condition来控制线程的等待/唤醒。

示例代码：
```java
import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;

public class ConditionExample {
    private final Lock lock = new ReentrantLock();
    private final Condition condition = lock.newCondition();

public void acquire() {
        try {
            // 获取锁
            lock.lock();
            System.out.println("Lock acquired");

// 设置条件，线程将等待该条件满足
            condition.signalAll(); // 提醒所有等待的线程

// 线程执行其他任务
            Thread.sleep(2000); // 休眠2秒

} catch (InterruptedException e) {
            e.printStackTrace();
        } finally {
            // 无论是否捕获异常，都要释放锁
            try {
                lock.unlock();
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    }

public void release() {
        condition.signalAll(); // 提醒所有等待的线程
    }

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

// 获取锁
        example.acquire();

// 线程执行其他任务
        Thread.sleep(2000); // 休眠2秒

// 设置条件，唤醒等待的线程
        example.release();
    }
}
```
在这个例子中，`acquire()`方法用于获取锁并等待条件满足，`release()`方法则用于唤醒等待的线程。