ReentrantLock并发锁:打造安全的Java多线程环境

后端

2024-01-09 02:18:17

一、ReentrantLock是什么

ReentrantLock是一种基于AQS框架的应用实现，它继承了AQS的同步队列，具有公平锁和非公平锁两种实现方式。ReentrantLock是一种可重入锁，这意味着同一个线程可以多次获取同一把锁，而不会造成死锁。

ReentrantLock的锁状态可以通过以下方法进行控制：

lock()：获取锁
unlock()：释放锁
tryLock()：尝试获取锁，如果锁已被占用，则立即返回false
tryLock(long time, TimeUnit unit)：尝试获取锁，如果锁已被占用，则最多等待指定的时间
lockInterruptibly()：获取锁，如果锁已被占用，则等待，直到锁被释放或线程被中断

二、ReentrantLock的使用方法

ReentrantLock的使用方法非常简单，只需要以下几个步骤：

创建一个ReentrantLock对象
使用lock()方法获取锁
在获取到锁之后，执行需要同步的代码
执行完毕后，使用unlock()方法释放锁

以下是一个使用ReentrantLock的示例代码：

import java.util.concurrent.locks.ReentrantLock;

public class ReentrantLockExample {

    private static ReentrantLock lock = new ReentrantLock();

    public static void main(String[] args) {
        // 创建一个线程
        Thread thread = new Thread(() -> {
            // 获取锁
            lock.lock();
            try {
                // 执行需要同步的代码
                System.out.println("线程" + Thread.currentThread().getName() + "获取到锁");
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            } finally {
                // 释放锁
                lock.unlock();
            }
        });

        // 启动线程
        thread.start();

        // 主线程也获取锁
        lock.lock();
        try {
            // 执行需要同步的代码
            System.out.println("主线程获取到锁");
            Thread.sleep(1000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        } finally {
            // 释放锁
            lock.unlock();
        }
    }
}