当前位置:

首页 > 编程开发 > 如何解决Java中轮询锁使用时遇到的问题?

如何解决Java中轮询锁使用时遇到的问题?

问题演示当我们没有使用轮询锁之前,可能会出现这样的问题:importjava.util.concurrent.locks.Lock;importjava.util.concurrent.locks.ReentrantLock;publicclassDeadLockByReentrantLock{publicstaticvoidmain(String[]args){LocklockA=newReentrantLock();//创建锁ALocklockB=newReentrantLock();//创建锁B//

本文目录

    问题演示

    当我们没有使用轮询锁之前,可能会出现这样的问题:

    import java.util.concurrent.locks.Lock;
    import java.util.concurrent.locks.ReentrantLock;
    public class DeadLockByReentrantLock {
        public static void main(String[] args) {
            Lock lockA = new ReentrantLock(); // 创建锁 A
            Lock lockB = new ReentrantLock(); // 创建锁 B
    
            // 创建线程 1
            Thread t1 = new Thread(new Runnable() {
                @Override
                public void run() {
                    lockA.lock(); // 加锁
                    System.out.println("线程 1:获取到锁 A!");
                    try {
                        Thread.sleep(1000);
                        System.out.println("线程 1:等待获取 B...");
                        lockB.lock(); // 加锁
                        try {
                            System.out.println("线程 1:获取到锁 B!");
                        } finally {
                            lockA.unlock(); // 释放锁
                        }
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    } finally {
                        lockA.unlock(); // 释放锁
                    }
                }
            });
            t1.start(); // 运行线程
    
            // 创建线程 2
            Thread t2 = new Thread(new Runnable() {
                @Override
                public void run() {
                    lockB.lock(); // 加锁
                    System.out.println("线程 2:获取到锁 B!");
                    try {
                        Thread.sleep(1000);
                        System.out.println("线程 2:等待获取 A...");
                        lockA.lock(); // 加锁
                        try {
                            System.out.println("线程 2:获取到锁 A!");
                        } finally {
                            lockA.unlock(); // 释放锁
                        }
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    } finally {
                        lockB.unlock(); // 释放锁
                    }
                }
            });
            t2.start(); // 运行线程
        }
    }

    以上代码的执行结果如下:

    如何解决Java中轮询锁使用时遇到的问题?

    从上述结果可以看出,此时程序中出现了线程相互等待,并尝试获取对方(锁)资源的情况,这就是典型的死锁问题了。

    简易版轮询锁

    当出现死锁问题之后,我们就可以使用轮询锁来解决它了,它的实现思路是通过轮询的方式来获取多个锁,如果中途有任意一个锁获取失败,则执行回退操作,释放当前线程拥有的所有锁,等待下一次重新执行,这样就可以避免多个线程同时拥有并霸占锁资源了,从而直接解决了死锁的问题,简易版的轮询锁实现如下:

    import java.util.concurrent.locks.Lock;
    import java.util.concurrent.locks.ReentrantLock;
    public class SolveDeadLockExample2 {
        public static void main(String[] args) {
            Lock lockA = new ReentrantLock(); // 创建锁 A
            Lock lockB = new ReentrantLock(); // 创建锁 B
    
            // 创建线程 1(使用轮询锁)
            Thread t1 = new Thread(new Runnable() {
                @Override
                public void run() {
                    // 调用轮询锁
                    pollingLock(lockA, lockB);
                }
            });
            t1.start(); // 运行线程
    
            // 创建线程 2
            Thread t2 = new Thread(new Runnable() {
                @Override
                public void run() {
                    lockB.lock(); // 加锁
                    System.out.println("线程 2:获取到锁 B!");
                    try {
                        Thread.sleep(1000);
                        System.out.println("线程 2:等待获取 A...");
                        lockA.lock(); // 加锁
                        try {
                            System.out.println("线程 2:获取到锁 A!");
                        } finally {
                            lockA.unlock(); // 释放锁
                        }
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    } finally {
                        lockB.unlock(); // 释放锁
                    }
                }
            });
            t2.start(); // 运行线程
        }
    
        /**
         * 轮询锁
         */
        private static void pollingLock(Lock lockA, Lock lockB) {
            // 轮询锁
            while (true) {
                if (lockA.tryLock()) { // 尝试获取锁
                    System.out.println("线程 1:获取到锁 A!");
                    try {
                        Thread.sleep(1000);
                        System.out.println("线程 1:等待获取 B...");
                        if (lockB.tryLock()) { // 尝试获取锁
                            try {
                                System.out.println("线程 1:获取到锁 B!");
                            } finally {
                                lockB.unlock(); // 释放锁
                                System.out.println("线程 1:释放锁 B.");
                                break;
                            }
                        }
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    } finally {
                        lockA.unlock(); // 释放锁
                        System.out.println("线程 1:释放锁 A.");
                    }
                }
                // 等待一秒再继续执行
                try {
                    Thread.sleep(1000);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        }
    }

    以上代码的执行结果如下:

    如何解决Java中轮询锁使用时遇到的问题?

    从上述结果可以看出,当我们在程序中使用轮询锁之后就不会出现死锁的问题了,但以上轮询锁也并不是完美无缺的,下面我们来看看这个轮询锁会有什么样的问题?

    问题1:死循环

    以上简易版的轮询锁,如果遇到有一个线程一直霸占或者长时间霸占锁资源的情况,就会导致这个轮询锁进入死循环的状态,它会尝试一直获取锁资源,这样就会造成新的问题,带来不必要的性能开销,具体示例如下。

    反例

    import java.util.concurrent.locks.Lock;
    import java.util.concurrent.locks.ReentrantLock;
    public class SolveDeadLockExample {
        public static void main(String[] args) {
            Lock lockA = new ReentrantLock(); // 创建锁 A
            Lock lockB = new ReentrantLock(); // 创建锁 B
    
            // 创建线程 1(使用轮询锁)
            Thread t1 = new Thread(new Runnable() {
                @Override
                public void run() {
                    // 调用轮询锁
                    pollingLock(lockA, lockB);
                }
            });
            t1.start(); // 运行线程
    
            // 创建线程 2
            Thread t2 = new Thread(new Runnable() {
                @Override
                public void run() {
                    lockB.lock(); // 加锁
                    System.out.println("线程 2:获取到锁 B!");
                    try {
                        Thread.sleep(1000);
                        System.out.println("线程 2:等待获取 A...");
                        lockA.lock(); // 加锁
                        try {
                            System.out.println("线程 2:获取到锁 A!");
                        } finally {
                            lockA.unlock(); // 释放锁
                        }
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    } finally {
                        // 如果此处代码未执行,线程 2 一直未释放锁资源
                        // lockB.unlock(); 
                    }
                }
            });
            t2.start(); // 运行线程
        }
    
        /**
         * 轮询锁
         */
        public static void pollingLock(Lock lockA, Lock lockB) {
            while (true) {
                if (lockA.tryLock()) { // 尝试获取锁
                    System.out.println("线程 1:获取到锁 A!");
                    try {
                        Thread.sleep(1000);
                        System.out.println("线程 1:等待获取 B...");
                        if (lockB.tryLock()) { // 尝试获取锁
                            try {
                                System.out.println("线程 1:获取到锁 B!");
                            } finally {
                                lockB.unlock(); // 释放锁
                                System.out.println("线程 1:释放锁 B.");
                                break;
                            }
                        }
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    } finally {
                        lockA.unlock(); // 释放锁
                        System.out.println("线程 1:释放锁 A.");
                    }
                }
                // 等待一秒再继续执行
                try {
                    Thread.sleep(1000);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        }
    }

    以上代码的执行结果如下: 

    如何解决Java中轮询锁使用时遇到的问题?

    从上述结果可以看出,线程 1 轮询锁进入了死循环的状态。

    优化版

    针对以上死循环的情况,我们可以改进的思路有以下两种:

    • 添加最大次数限制:如果经过了 n 次尝试获取锁之后,还未获取到锁,则认为获取锁失败,执行失败策略之后终止轮询(失败策略可以是记录日志或其他操作);

    • 添加最大时长限制:如果经过了 n 秒尝试获取锁之后,还未获取到锁,则认为获取锁失败,执行失败策略之后终止轮询。

    以上策略任选其一就可以解决死循环的问题,出于实现成本的考虑,我们可以采用轮询最大次数的方式来改进轮询锁,

    具体实现代码如下:

    import java.util.concurrent.locks.Lock;
    import java.util.concurrent.locks.ReentrantLock;
    
    public class SolveDeadLockExample {
    
        public static void main(String[] args) {
            Lock lockA = new ReentrantLock(); // 创建锁 A
            Lock lockB = new ReentrantLock(); // 创建锁 B
    
            // 创建线程 1(使用轮询锁)
            Thread t1 = new Thread(new Runnable() {
                @Override
                public void run() {
                    // 调用轮询锁
                    pollingLock(lockA, lockB, 3);
                }
            });
            t1.start(); // 运行线程
    
            // 创建线程 2
            Thread t2 = new Thread(new Runnable() {
                @Override
                public void run() {
                    lockB.lock(); // 加锁
                    System.out.println("线程 2:获取到锁 B!");
                    try {
                        Thread.sleep(1000);
                        System.out.println("线程 2:等待获取 A...");
                        lockA.lock(); // 加锁
                        try {
                            System.out.println("线程 2:获取到锁 A!");
                        } finally {
                            lockA.unlock(); // 释放锁
                        }
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    } finally {
                        // 线程 2 忘记释放锁资源
                        // lockB.unlock(); // 释放锁
                    }
                }
            });
            t2.start(); // 运行线程
        }
    
        /**
         * 轮询锁
         *
         * maxCount:最大轮询次数
         */
        public static void pollingLock(Lock lockA, Lock lockB, int maxCount) {
            // 轮询次数计数器
            int count = 0;
            while (true) {
                if (lockA.tryLock()) { // 尝试获取锁
                    System.out.println("线程 1:获取到锁 A!");
                    try {
                        Thread.sleep(1000);
                        System.out.println("线程 1:等待获取 B...");
                        if (lockB.tryLock()) { // 尝试获取锁
                            try {
                                System.out.println("线程 1:获取到锁 B!");
                            } finally {
                                lockB.unlock(); // 释放锁
                                System.out.println("线程 1:释放锁 B.");
                                break;
                            }
                        }
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    } finally {
                        lockA.unlock(); // 释放锁
                        System.out.println("线程 1:释放锁 A.");
                    }
                }
    
                // 判断是否已经超过最大次数限制
                if (count++ > maxCount) {
                    // 终止循环
                    System.out.println("轮询锁获取失败,记录日志或执行其他失败策略");
                    return;
                }
    
                // 等待一秒再继续尝试获取锁
                try {
                    Thread.sleep(1000);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        }
    }

    以上代码的执行结果如下:

    如何解决Java中轮询锁使用时遇到的问题?

    从以上结果可以看出,当我们改进之后,轮询锁就不会出现死循环的问题了,它会尝试一定次数之后终止执行。

    问题2:线程饿死

    我们以上的轮询锁的轮询等待时间是固定时间,如下代码所示:

    // 等待 1s 再尝试获取(轮询)锁
    try {
        Thread.sleep(1000);
    } catch (InterruptedException e) {
        e.printStackTrace();
    }

    这样在特殊情况下会造成线程饿死的问题,也就是轮询锁一直获取不到锁的问题,比如以下示例。

    反例

    import java.util.concurrent.locks.Lock;
    import java.util.concurrent.locks.ReentrantLock;
    
    public class SolveDeadLockExample {
    
        public static void main(String[] args) {
            Lock lockA = new ReentrantLock(); // 创建锁 A
            Lock lockB = new ReentrantLock(); // 创建锁 B
    
            // 创建线程 1(使用轮询锁)
            Thread t1 = new Thread(new Runnable() {
                @Override
                public void run() {
                    // 调用轮询锁
                    pollingLock(lockA, lockB, 3);
                }
            });
            t1.start(); // 运行线程
    
            // 创建线程 2
            Thread t2 = new Thread(new Runnable() {
                @Override
                public void run() {
                    while (true) {
                        lockB.lock(); // 加锁
                        System.out.println("线程 2:获取到锁 B!");
                        try {
                            System.out.println("线程 2:等待获取 A...");
                            lockA.lock(); // 加锁
                            try {
                                System.out.println("线程 2:获取到锁 A!");
                            } finally {
                                lockA.unlock(); // 释放锁
                            }
                        } finally {
                            lockB.unlock(); // 释放锁
                        }
                        // 等待一秒之后继续执行
                        try {
                            Thread.sleep(1000);
                        } catch (InterruptedException e) {
                            e.printStackTrace();
                        }
                    }
                }
            });
            t2.start(); // 运行线程
        }
    
        /**
         * 轮询锁
         */
        public static void pollingLock(Lock lockA, Lock lockB, int maxCount) {
            // 循环次数计数器
            int count = 0;
            while (true) {
                if (lockA.tryLock()) { // 尝试获取锁
                    System.out.println("线程 1:获取到锁 A!");
                    try {
                        Thread.sleep(100); // 等待 0.1s(获取锁需要的时间)
                        System.out.println("线程 1:等待获取 B...");
                        if (lockB.tryLock()) { // 尝试获取锁
                            try {
                                System.out.println("线程 1:获取到锁 B!");
                            } finally {
                                lockB.unlock(); // 释放锁
                                System.out.println("线程 1:释放锁 B.");
                                break;
                            }
                        }
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    } finally {
                        lockA.unlock(); // 释放锁
                        System.out.println("线程 1:释放锁 A.");
                    }
                }
    
                // 判断是否已经超过最大次数限制
                if (count++ > maxCount) {
                    // 终止循环
                    System.out.println("轮询锁获取失败,记录日志或执行其他失败策略");
                    return;
                }
    
                // 等待一秒再继续尝试获取锁
                try {
                    Thread.sleep(1000);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        }
    }

    以上代码的执行结果如下:

    如何解决Java中轮询锁使用时遇到的问题?

    从上述结果可以看出,线程 1(轮询锁)一直未成功获取到锁,造成这种结果的原因是:线程 1 每次轮询的等待时间为固定的 1s,而线程 2 也是相同的频率,每 1s 获取一次锁,这样就会导致线程 2 会一直先成功获取到锁,而线程 1 则会一直处于“饿死”的情况,执行流程如下图所示:

    如何解决Java中轮询锁使用时遇到的问题?

    优化版

    接下来,我们可以将轮询锁的固定等待时间,改进为固定时间 + 随机时间的方式,这样就可以避免因为获取锁的频率一致,而造成轮询锁“饿死”的问题了,具体实现代码如下:

    import java.util.Random;
    import java.util.concurrent.locks.Lock;
    import java.util.concurrent.locks.ReentrantLock;
    
    public class SolveDeadLockExample {
        private static Random rdm = new Random();
    
        public static void main(String[] args) {
            Lock lockA = new ReentrantLock(); // 创建锁 A
            Lock lockB = new ReentrantLock(); // 创建锁 B
    
            // 创建线程 1(使用轮询锁)
            Thread t1 = new Thread(new Runnable() {
                @Override
                public void run() {
                    // 调用轮询锁
                    pollingLock(lockA, lockB, 3);
                }
            });
            t1.start(); // 运行线程
    
            // 创建线程 2
            Thread t2 = new Thread(new Runnable() {
                @Override
                public void run() {
                    while (true) {
                        lockB.lock(); // 加锁
                        System.out.println("线程 2:获取到锁 B!");
                        try {
                            System.out.println("线程 2:等待获取 A...");
                            lockA.lock(); // 加锁
                            try {
                                System.out.println("线程 2:获取到锁 A!");
                            } finally {
                                lockA.unlock(); // 释放锁
                            }
                        } finally {
                            lockB.unlock(); // 释放锁
                        }
                        // 等待一秒之后继续执行
                        try {
                            Thread.sleep(1000);
                        } catch (InterruptedException e) {
                            e.printStackTrace();
                        }
                    }
                }
            });
            t2.start(); // 运行线程
        }
    
        /**
         * 轮询锁
         */
        public static void pollingLock(Lock lockA, Lock lockB, int maxCount) {
            // 循环次数计数器
            int count = 0;
            while (true) {
                if (lockA.tryLock()) { // 尝试获取锁
                    System.out.println("线程 1:获取到锁 A!");
                    try {
                        Thread.sleep(100); // 等待 0.1s(获取锁需要的时间)
                        System.out.println("线程 1:等待获取 B...");
                        if (lockB.tryLock()) { // 尝试获取锁
                            try {
                                System.out.println("线程 1:获取到锁 B!");
                            } finally {
                                lockB.unlock(); // 释放锁
                                System.out.println("线程 1:释放锁 B.");
                                break;
                            }
                        }
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    } finally {
                        lockA.unlock(); // 释放锁
                        System.out.println("线程 1:释放锁 A.");
                    }
                }
    
                // 判断是否已经超过最大次数限制
                if (count++ > maxCount) {
                    // 终止循环
                    System.out.println("轮询锁获取失败,记录日志或执行其他失败策略");
                    return;
                }
    
                // 等待一定时间(固定时间 + 随机时间)之后再继续尝试获取锁
                try {
                    Thread.sleep(300 + rdm.nextInt(8) * 100); // 固定时间 + 随机时间
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        }
    }

    以上代码的执行结果如下:

    如何解决Java中轮询锁使用时遇到的问题?

    从上述结果可以看出,线程 1(轮询锁)加入随机等待时间之后就不会出现线程饿死的问题了。

    本站声明:本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系bd@zhengruan.com
    作者最新文章
    编程开发 Java
    相关文章 更多
    Yandex官网入口及网页搜索使用方法
    Yandex官网入口及网页搜索使用方法

    Yandex官网入口是https://www.yondex.net/,该平台支持多语言切换、智能搜索匹配、虚拟键盘变更及实时翻译,提供地图、图片、新闻、购物等垂直服务,并具备账户同步、隐私管理、个性化首页和云存储等功能。

    Java单元测试入门:使用JUnit 5编写第一个测试用例
    Java单元测试入门:使用JUnit 5编写第一个测试用例

    面向初学者的JUnit 5实用入门指南。从测试概念、Maven依赖配置,到手把手编写首个单元测试用例及断言验证,助你掌握Java单元测试的核心流程。

    Java变量未初始化报错解析:局部变量与成员变量默认值差异
    Java变量未初始化报错解析:局部变量与成员变量默认值差异

    深入解析Java中局部变量未初始化编译报错与成员变量自动赋予默认值的机制差异,涵盖JVM内存分配、编译期确定性赋值检查与实际排查修复方案。

    Java获取当前时间并格式化输出:DateTimeFormatter与SimpleDateFormat
    Java获取当前时间并格式化输出:DateTimeFormatter与SimpleDateFormat

    详细讲解在Java中获取当前系统时间并进行格式化输出的两种核心方案:基于Java 8全新日期时间API的DateTimeFormatter与传统遗留的SimpleDateFormat,包含完整代码示例、线程安全机制对比及生产选型建议。

    Java中final与static final常量的定义及初始化规则
    Java中final与static final常量的定义及初始化规则

    深入解析Java中final变量与static final常量的定义、内存语义、初始化时机及合法赋值路径,涵盖编译期常量优化与实战避坑指南。

    Java抽象方法与接口方法的区别及选型建议
    Java抽象方法与接口方法的区别及选型建议

    深入对比Java中抽象类抽象方法与接口方法的语法演进、设计意图及运行期差异,并提供清晰的架构选型决策流程与实战范例。

    Java实现HTTP请求与JSON解析的完整代码示例
    Java实现HTTP请求与JSON解析的完整代码示例

    本文提供Java标准库HttpClient发起HTTP GET/POST请求并结合Jackson进行JSON数据反序列化与序列化的完整代码示例与工程实践指南。

    Java递归出现StackOverflowError的原因分析及栈空间优化方案
    Java递归出现StackOverflowError的原因分析及栈空间优化方案

    详细分析Java递归调用出现StackOverflowError的原因,结合代码说明线程栈、栈帧和递归深度之间的关系,并介绍终止条件排查、迭代改写、减少栈帧开销以及通过-Xss调整JVM栈空间的方法。

    Java空指针异常(NPE)的代码排查与修复实例
    Java空指针异常(NPE)的代码排查与修复实例

    针对Java中常见的NullPointerException(NPE),本文从堆栈日志定位、典型代码触发场景、具体修复代码对比到防御体系进行系统讲解,提供实用且易上手的排查与修复方案。

    selenium上传文件教程本地文件路径设置方法
    selenium上传文件教程本地文件路径设置方法

    深入解析Selenium处理文件上传的技术细节,涵盖标准HTML控件的路径直接注入法与非标准控件的系统级模拟方案,提供Windows与Linux环境下的路径设置最佳实践及常见异常排查。

    查看更多
    精品专题 更多
    装机必备
    装机必备

    正软商城装机必备专区,精选办公、浏览器、安全防护、影音播放、压缩解压、设计创作和系统工具等电脑常用正版软件,帮助用户快速完成新电脑软件配置。

    Windows
    Windows

    正软商城Windows软件专区,汇集适用于Windows电脑的办公、设计、安全防护、影音播放、开发工具和系统优化软件,提供软件介绍、系统要求、正版授权及购买下载服务。

    PDF教程
    PDF教程

    正软商城PDF教程频道提供PDF编辑、转换、合并、拆分、压缩及格式处理方法,同时介绍常用PDF软件和工具的使用技巧。

    Mac软件 更多
    讯飞智作 网页版
    讯飞智作 网页版
    Windows/ macOS/ Linux

    讯飞智作是一款基于语音合成技术、虚拟人驱动技术与数字人形象声音构建能力的 AI 数字人音视频创作平台。

    火山引擎 网页版
    火山引擎 网页版
    Windows/ macOS/ Linux

    火山引擎是字节跳动旗下企业级云与AI服务平台。聚焦大模型核心能力,依托字节自研豆包多模态大模型,凭借火山方舟一站式平台,提供模型精调、推理部署、智能应用搭建等全链路服务,结合高性能AI算力,助力各行业快速落地大模型数字化与智能化应用。

    Aperty macOS版
    Aperty macOS版
    macOS

    Aperty 是 Skylum 推出的 AI 人像修图软件,支持自然肤质修饰、瑕疵处理、面部与身体调整、预设及批量同步。

    WINDOWS 更多
    讯飞智作 网页版
    讯飞智作 网页版
    Windows/ macOS/ Linux

    讯飞智作是一款基于语音合成技术、虚拟人驱动技术与数字人形象声音构建能力的 AI 数字人音视频创作平台。

    火山引擎 网页版
    火山引擎 网页版
    Windows/ macOS/ Linux

    火山引擎是字节跳动旗下企业级云与AI服务平台。聚焦大模型核心能力,依托字节自研豆包多模态大模型,凭借火山方舟一站式平台,提供模型精调、推理部署、智能应用搭建等全链路服务,结合高性能AI算力,助力各行业快速落地大模型数字化与智能化应用。

    PixTV 网页版
    PixTV 网页版
    Windows

    PixTV 是一款在浏览器中使用的 AI 视觉内容创作平台,提供图片、视频、音频、文字生成、AI 分镜、局部重绘、提示词反推和无限画布等工具,适合短剧、漫剧、广告及社交媒体内容制作。