zoukankan      html  css  js  c++  java
  • java~ReentrantLock的介绍

    ReentrantLock

    java除了使用关键字synchronized外,还可以使用ReentrantLock实现独占锁的功能。而且ReentrantLock相比synchronized而言功能更加丰富,使用起来更为灵活,也更适合复杂的并发场景。这篇文章主要是从使用的角度来分析一下ReentrantLock。

    ReentrantLock与synchronized来的区别

    1. synchronized是独占锁,加锁和解锁的过程自动进行,易于操作,但不够灵活。ReentrantLock也是独占锁,加锁和解锁的过程需要手动进行,不易操作,但非常灵活。
    2. synchronized可重入,因为加锁和解锁自动进行,不必担心最后是否释放锁;ReentrantLock也可重入,但加锁和解锁需要手动进行,且次数需一样,否则其他线程无法获得锁。
    3. synchronized不可响应中断,一个线程获取不到锁就一直等着;ReentrantLock可以相应中断。

    isFair()、isHeldByCurrentThread()和isLocked()

    1. lock.isFair()方法用来判断lock锁是公平锁还是非公平锁。公平锁是指,线程获得锁的顺序是按其等待锁的先后顺序来的,先来先获得FIFO。反之,非公平锁则是线程随机获得锁的,lock默认是非公平锁。
    2. lock.isHeldByCurrentThread()的作用是查询当前线程是否保持此锁定,和lock.hasQueueThread()不同的地方是:lock.hasQueueThread(Thread thread)的作用是判断当前线程是否处于等待lock的状态。
    3. lock.isLocked()的作用是查询此锁定是否由任意线程保持。

    spring redis lock里有对ReentrantLock的使用,org.springframework.integration.redis.util.RedisLockRegistry,有兴趣可以看一下它的源码。

    用法示例

    一 isFair()方法用来判断lock锁是公平锁还是非公平锁

    public class ServiceIsFair {
        public ReentrantLock lock;
     
        public ServiceIsFair(Boolean isFair) {
            this.lock = new ReentrantLock(isFair);
        }
     
        public void serviceMethod(){
            try {
                lock.lock();
                System.out.println("公平锁情况:"+lock.isFair());
            } finally {
                lock.unlock();
            }
        }
    }
    

    二 lock.isHeldByCurrentThread()的作用是查询当前线程是否保持此锁定,与lock.hasQueueThread()不同的地方是:lock.hasQueueThread(Thread thread)的作用是判断当前线程是否处于等待lock的状态

    public class ServiceIsHeldByCurrentThread {
        private ReentrantLock lock;
     
        public ServiceIsHeldByCurrentThread(Boolean isFair) {
            this.lock = new ReentrantLock(isFair);
        }
     
        public void serviceMethod(){
            try {
                System.out.println("lock.isHeldByCurrentThread() "+lock.isHeldByCurrentThread());
                lock.lock();
                System.out.println("lock.isHeldByCurrentThread() "+lock.isHeldByCurrentThread());
            } finally {
                lock.unlock();
            }
        }
    }
    

    三 lock.isLocked()的作用是查询此锁定是否由任意线程保持

    public class ServiceIsLocked {
        private ReentrantLock lock;
     
        public ServiceIsLocked(Boolean isFair) {
            this.lock = new ReentrantLock(isFair);
        }
     
        public void serviceMethod(){
            try {
                System.out.println("lock.isLocked() "+lock.isLocked());
                lock.lock();
                System.out.println("lock.isLocked() "+lock.isLocked());
            } finally {
                lock.unlock();
            }
        }
    }
    

  • 相关阅读:
    Thinkphp中自己组合的数据怎样使用框架的分页
    CI框架不能有Index控制器
    购物车,修改数量错误
    TypeError: 'stepUp' called on an object that does not implement interface HTMLInputElement.
    OAuth2.0
    通过控制面板查看时间日志
    js再学习笔记
    Thinkphp验证码异步验证第二次及以后验证,验证错误----待解决
    cookie&&session再理解笔记
    markdown语法学习笔记
  • 原文地址:https://www.cnblogs.com/lori/p/13539489.html
Copyright © 2011-2022 走看看