Java并发库工具Lock和Condition的用法实例

原创川长思鸟来 2024-09-06 00:36 89阅读 0赞

在Java中，`java.util.concurrent.locks.Lock`用于锁定资源，而`java.util.concurrent.Condition`则用于实现线程间的同步与通信。

以下是一些具体用法实例：

1. 锁（Lock）
```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() {
        lock.lock();
        System.out.println("Acquired the lock");
    }

public void release() {
        try {
            lock.unlock();
            System.out.println("Released the lock");
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

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

example.acquire(); // Acquire the lock

// Do some tasks that require the lock

Thread.sleep(2000); // Sleep for a bit to simulate doing something else

example.release(); // Release the lock
    }
}
```
2. 条件（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 await() throws InterruptedException {
        lock.lock();
        try {
            condition.await();
        } finally {
            lock.unlock();
        }
    }

public void signal() {
        lock.lock();
        try {
            condition.signal();
        } finally {
            lock.unlock();
        }
    }

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

example.lock(); // Acquire the lock

example.await(); // Wait until signaled

System.out.println("Signaled");

example.signal(); // Signal a waiting thread

example.release(); // Release the lock
    }
}
```
以上两个例子展示了如何使用Java并发库中的Lock和Condition工具进行同步与通信。