redis锁实现_IDEA使用try

redis锁实现_IDEA使用tryWeb全栈~35.显式锁上一期接口Lock显式锁接口的定义       lock()/unlock():就是普通的获取锁和释放锁方法,lock()会阻塞直到成功。       lockInterruptibly():与lock()的不同是,它可以响应中断,如果被其他线程中断了,则抛出InterruptedException。  &nbsp

大家好,又见面了,我是你们的朋友全栈君。如果您正在找激活码,请点击查看最新教程,关注关注公众号 “全栈程序员社区” 获取激活教程,可能之前旧版本教程已经失效.最新Idea2022.1教程亲测有效,一键激活。

Jetbrains全系列IDE稳定放心使用

Web全栈~35.显式锁

上一期

接口Lock

显式锁接口的定义

在这里插入图片描述

       lock()/unlock():就是普通的获取锁和释放锁方法,lock()会阻塞直到成功。

       lockInterruptibly():与lock()的不同是,它可以响应中断,如果被其他线程中断了,则抛出InterruptedException。

       tryLock():只是尝试获取锁,立即返回,不阻塞,如果获取成功,返回true,否则返回false。

       tryLock(long time,TimeUnit unit):先尝试获取锁,如果能成功则立即返回true,否则阻塞等待,但等待的最长时间由指定的参数设置,在等待的同时响应中断,如果发生了中断,抛出InterruptedException,如果在等待的时间内获得了锁,返回true,否则返回false。

       newCondition:新建一个条件,一个Lock可以关联多个条件

       可以看出,相比synchronized,显式锁支持以非阻塞方式获取锁、可以响应中断、可以限时,这使得它灵活得多。

ReentrantLock

       Lock接口的主要实现类是ReentrantLock,它的基本用法lock/unlock实现了与synchronized一样的语义

       ReentrantLock有两个构造方法

在这里插入图片描述

       参数fair表示是否保证公平,不指定的情况下,默认为false,表示不保证公平。所谓公平是指,等待时间最长的线程优先获得锁。保证公平会影响性能,一般也不需要,所以默认不保证,synchronized锁也是不保证公平的

       使用显式锁,一定要记得调用unlock。一般而言,应该将lock之后的代码包装到try语句内,在finally语句内释放锁。

代码示例

 public void fun() { 
   
      lock.lock();
      try{ 
   
          count++;
      }finally { 
   
          lock.unlock();
      }
  } 

使用tryLock()避免死锁

       使用tryLock(),可以避免死锁。在持有一个锁获取另一个锁而获取不到的时候,可以释放已持有的锁,给其他线程获取锁的机会,然后重试获取所有锁。

银行转账实例

账户类
class Account{ 
   
    private Lock lock = new ReentrantLock();
    private volatile double money;
    public Account(double initialMoney){ 
   
        this.money = initialMoney;
    }
    public void add(double money){ 
   
        lock.lock();
        try{ 
   
            this.money = money;
        }finally { 
   
            lock.unlock();
        }
    }
    public void reduce(double money){ 
   
        lock.lock();
        try{ 
   
            this.money -= money;
        }finally { 
   
            lock.unlock();
        }
    }
    public double getMoney() { 
   
        return money;
    }
    public void lock(){ 
   
        lock.lock();
    }
    public void unlock(){ 
   
        lock.unlock();
    }
    public boolean tryLock(){ 
   
        return lock.tryLock();
    }
}

       在账户之间转账,需要两个账户都锁定,如果不使用tryLock,而直接使用lock就会发生死锁。这里可以试一试

class NoEnoughMoney extends Exception { 
   
    public static void transfer(Account from,Account to,double money)
        throws NoEnoughMoney { 
   
        from.lock();
        try { 
   
            to.lock();
            try { 
   
            if(from.getMoney() >= money) { 
   
                from.reduce(money);
                to.add(money);
            } else { 
   
                throw new NoEnoughMoney();
            }
            } finally { 
   
                to.unlock();
            }
        } finally { 
   
            from.unlock();
        }
    }
}
模拟死锁的过程
public static void simulateDeadLock() { 
   
    final int accountNum = 10;
    final Account[]accounts = new Account[accountNum];
    final Random rnd = new Random();
    for(int i = 0; i < accountNum; i++) { 
   
        accounts[i]= new Account(rnd.nextInt(10000));
    }
    int threadNum = 100;
    Thread[]threads = new Thread[threadNum];
    for(int i = 0; i < threadNum; i++) { 
   
        threads[i]= new Thread() { 
   
            public void run() { 
   
                int loopNum = 100;
                for(int k = 0; k < loopNum; k++) { 
   
                    int i = rnd.nextInt(accountNum);
                    int j = rnd.nextInt(accountNum);
                    int money = rnd.nextInt(10);
                    if(i!= j) { 
   
                        try { 
   
                            transfer(accounts[i],accounts[j],money);
                        } catch (NoEnoughMoney e) { 
   
                        }
                    }
                }
            }
        };
        threads[i].start();
    }
}

       这里有10个账户,100个线程,每个线程执行100次循环,在每次循环中,随机挑选两个账户进行转账。每次执行该段代码都会发生死锁。

使用tryLock实现转账

public static boolean tryTransfer(Account from,Account to,double money) throws NoEnoughMoney { 
   
        if(from.tryLock()) { 
   
            try { 
   
                if(to.tryLock()) { 
   
                    try { 
   
                        if(from.getMoney() >= money) { 
   
                            from.reduce(money);
                            to.add(money);
                        } else { 
   
                            throw new NoEnoughMoney();
                        }
                        return true;
                    } finally { 
   
                        to.unlock();
                    }
                }
            } finally { 
   
                from.unlock();
            }
        }
        return false;
    }

       如果两个锁都能够获得,且转账成功,则返回true,否则返回false。不管怎样,结束都会释放所有锁。

       transfer方法可以循环调用该方法以避免死锁

public static void transfer(Account from,Account to,double money) throws NoEnoughMoney { 
   
    boolean success = false;
    do { 
   
        success = tryTransfer(from,to,money);
        if(!success) { 
   
            Thread.yield();
        }
    } while (!success);
}
版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

发布者:全栈程序员-站长,转载请注明出处:https://javaforall.net/181684.html原文链接:https://javaforall.net

赞 (0)
全栈程序员-站长的头像全栈程序员-站长


相关推荐

  • 【一键新机】免root/不刷机/拒绝Xposed 实现 Android改机,全新技术分析。「建议收藏」

    【一键新机】免root/不刷机/拒绝Xposed 实现 Android改机,全新技术分析。「建议收藏」此篇文章仅探讨Android底层技术。不提供任何软件和安装包……我们通过一些底层技术对手机中的各种基础信息进行一个修改。主要修改的参数有:Android_Id、IMEI、手机序列号、手机号码、WIFI-MAC、WIFI-Name、安卓系统版本、ROM固件、手机号码、手机型号、手机品牌、CPU型号、手机制造商、GPS定位、通话记录模拟、手机短信模拟……等各类安卓手机系统信息的修改功能…

    2022年6月8日
  • linux 普通用户修改环境变量_更改环境变量怎么设置

    linux 普通用户修改环境变量_更改环境变量怎么设置Linux环境变量设置文件/etc/profile全局用户,应用于所有的Shell。/$HOME/.profile当前用户,应用于所有的Shell。/etc/bash_bashrc全局用户,应用于BashShell。~/.bashrc局部当前,应用于BashSell。查找软件安装目录whereismongodb或者whichjava查看PATH#echo…

    2022年9月2日
  • 智能体脂秤解决方案[通俗易懂]

    这几年,随着智能科技的崛起,一大波智能产品纷纷上线,其中就有这不得不说的智能体脂秤。生活越来越富足的同时,体重也随之增长。人们对于健康的重视逐渐提升,体脂秤的功能也不只局限于称体重,还有很多一般体脂秤没有的功能。    智能体脂秤方案工作原理    智能秤其实是使用了生物电阻抗技术,在秤的表面加入了ITO导电膜或许导电金属片,当人体光脚踩上去之后会组成闭环电极,由于脂肪不导电而水分导电,所以可以通过计算电流值、电阻值配合体重值,来计算身体里脂肪的含量。换句话说,要测脂肪率,就必须赤脚上阵。   

    2022年4月9日
  • Idea激活码永久有效Idea2018.1.7激活码教程-持续更新,一步到位

    Idea激活码永久有效Idea2018.1.7激活码教程-持续更新,一步到位Idea激活码永久有效2018.1.7激活码教程-Windows版永久激活-持续更新,Idea激活码2018.1.7成功激活

    2022年6月17日
  • Java基础三:Java 核心技术[通俗易懂]

    Java基础三:Java 核心技术[通俗易懂]目录3.Java核心技术3.1.反射机制3.2.异常3.3.多线程3.4.文件与I\O流3.Java核心技术3.1.反射机制JAVA反射机制是在运行状态中,对于任意一个类,都能够知道这个类的所有属性和方法;对于任意一个对象,都能够调用它的任意一个方法和属性;这种动态获取的信息以及动态调用对象的方法的功能称为java语言的反射机制。3.1.1.静态编译和动态编译静态编译:在编译时确定类型,绑定对象 动态编译:运行时确定类型,绑定对象3

    2022年7月8日
  • 深入理解 RocketMQ

    深入理解 RocketMQ本文对RocketMQ的仅做理论性阐述,以便更深入的理解RocketMQ的内部机制,遇到棘手的问题更容易入手解决。关于代码实战请参考鄙人的另一篇文章:RocketMQ 入门使用详解

    2022年6月17日

发表回复

您的邮箱地址不会被公开。 必填项已用 * 标注

关注全栈程序员社区公众号