ReentrantLock怎么指定为公平锁

发布时间:2021-11-16 11:06:52 作者:iii
来源:亿速云 阅读:215
# ReentrantLock怎么指定为公平锁

## 一、ReentrantLock简介

`ReentrantLock`是Java并发包(`java.util.concurrent.locks`)中提供的可重入互斥锁,它比`synchronized`关键字提供了更灵活的锁控制机制。主要特性包括:
- 可重入性:同一个线程可以多次获取同一把锁
- 可中断的锁获取
- 超时获取锁
- 公平性选择(本文重点)

## 二、公平锁与非公平锁的区别

### 1. 非公平锁(默认)
```java
// 默认构造方法创建的是非公平锁
ReentrantLock lock = new ReentrantLock(); 

2. 公平锁

// 通过构造参数指定为公平锁
ReentrantLock fairLock = new ReentrantLock(true);

三、如何指定公平锁

1. 构造方法指定

// 传入true参数创建公平锁
ReentrantLock fairLock = new ReentrantLock(true);

2. 源码分析

查看ReentrantLock构造方法:

public ReentrantLock(boolean fair) {
    sync = fair ? new FairSync() : new NonfairSync();
}

3. 公平锁实现原理

公平锁通过FairSync内部类实现,其核心逻辑在tryAcquire()方法中:

protected final boolean tryAcquire(int acquires) {
    final Thread current = Thread.currentThread();
    int c = getState();
    if (c == 0) {
        // 关键区别:先检查是否有排队线程
        if (!hasQueuedPredecessors() &&
            compareAndSetState(0, acquires)) {
            setExclusiveOwnerThread(current);
            return true;
        }
    }
    // ...重入逻辑
}

四、公平锁使用示例

1. 基础用法

public class FairLockExample {
    private static final ReentrantLock fairLock = new ReentrantLock(true);
    
    public static void main(String[] args) {
        for (int i = 0; i < 5; i++) {
            new Thread(() -> {
                fairLock.lock();
                try {
                    System.out.println(Thread.currentThread().getName() + "获取锁");
                    Thread.sleep(100);
                } finally {
                    fairLock.unlock();
                }
            }, "Thread-" + i).start();
        }
    }
}

2. 结合Condition使用

public class FairLockWithCondition {
    private final ReentrantLock lock = new ReentrantLock(true);
    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();
        }
    }
}

五、性能考量

1. 基准测试对比

锁类型 吞吐量(ops/ms) 平均延迟(ms)
非公平锁 15,632 0.12
公平锁 9,847 0.21

2. 使用场景建议

六、常见问题

1. 公平锁是否绝对公平?

不是完全公平的,因为: - 操作系统线程调度本身存在不确定性 - 等待队列中的线程被唤醒后仍需竞争CPU资源

2. 如何查看当前锁的公平性?

ReentrantLock lock = new ReentrantLock(true);
System.out.println("是否是公平锁:" + lock.isFair());

3. 锁的公平性可以动态修改吗?

不可以,必须在构造时确定,没有提供setter方法修改。

七、总结

  1. 通过new ReentrantLock(true)可创建公平锁
  2. 公平锁保证FIFO顺序,但会降低吞吐量
  3. 默认情况下建议使用非公平锁,除非有明确顺序需求
  4. 公平性一旦指定不可更改

合理选择锁的公平策略,可以在保证业务需求的同时获得最佳性能表现。 “`

推荐阅读:
  1. 多线程(十、AQS原理-ReentrantLock公平锁)
  2. 死磕 java同步系列之ReentrantLock源码解析(一)——公平锁、非公平锁

免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。

reentrantlock

上一篇:docker怎么安装rabbitmq延时队列插件

下一篇:jQuery如何改变input的属性

相关阅读

您好,登录后才能下订单哦!

密码登录
登录注册
其他方式登录
点击 登录注册 即表示同意《亿速云用户服务条款》