首页 > 其他分享 >死锁的产生及避免

死锁的产生及避免

时间:2023-06-02 17:38:35浏览次数:66  
标签:obj1 LockA 产生 避免 println 死锁 obj2 Date new


资料

什么是死锁?死锁的产生条件及解决办法什么是死锁,死锁的原因及解决办法(含四个必要条件)死锁的产生原因与解决方法Java 实例 - 死锁及解决方法

实例

  • 产生死锁的四个必要条件:
  • 1、互斥使用,即当资源被一个线程使用(占有)时,别的线程不能使用
  • 2、不可抢占,资源请求者不能强制从资源占有者手中夺取资源,资源只能由资源占有者主动释放。
  • 3、请求和保持,即当资源请求者在请求其他的资源的同时保持对原有资源的占有。
  • 4、循环等待,即存在一个等待队列:P1占有P2的资源,P2占有P3的资源,P3占有P1的资源。这样就形成了一个等待环路。
/**
 * https://www.runoob.com/java/thread-deadlock.html
 * <p>产生死锁的四个必要条件:
 * <p>1、互斥使用,即当资源被一个线程使用(占有)时,别的线程不能使用</p>
 * <p>2、不可抢占,资源请求者不能强制从资源占有者手中夺取资源,资源只能由资源占有者主动释放。</p>
 * <p>3、请求和保持,即当资源请求者在请求其他的资源的同时保持对原有资源的占有。</p>
 * <p>4、循环等待,即存在一个等待队列:P1占有P2的资源,P2占有P3的资源,P3占有P1的资源。这样就形成了一个等待环路。</p>
 *
 * <p>运行结果</p>
 * <p>Fri Oct 14 20:42:12 CST 2022 LockA 开始执行</p>
 * <p>Fri Oct 14 20:42:12 CST 2022 LockB 开始执行</p>
 * <p>Fri Oct 14 20:42:12 CST 2022 LockB 锁住obj2</p>
 * <p>Fri Oct 14 20:42:12 CST 2022 LockA 锁住obj1</p>
 * <p>|</p>
 */
public class Main {
    public static String obj1 = "obj1";
    public static String obj2 = "obj2";

    public static void main(String[] args) throws InterruptedException {
        LockA lockA = new LockA();
        new Thread(lockA).start();
        LockB lockB = new LockB();
        new Thread(lockB).start();
    }

    static class LockA implements Runnable {
        @Override
        public void run() {
            try {
                System.out.println(new Date() + " LockA 开始执行");
                while (true) {
                    synchronized (obj1) {
                        System.out.println(new Date() + " LockA 锁住obj1 开始等待3秒");
                        Thread.sleep(3000); // 此处等待是给B能锁住机会
                        synchronized (obj2) {
                            System.out.println(new Date() + " LockA 锁住obj2");
                            Thread.sleep(60 * 1000); //为测试,占用了就不放
                        }
                    }
                }
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    }

    static class LockB implements Runnable {
        @Override
        public void run() {
            try {
                System.out.println(new Date() + " LockB 开始执行");
                while (true) {
                    synchronized (obj2) {
                        System.out.println(new Date() + " LockB 锁住obj2, 开始等待3秒");
                        Thread.sleep(3000); // 此处等待是给A能锁住的机会
                        synchronized (obj1) {
                            System.out.println(new Date() + " LockB锁住obj1");
                            Thread.sleep(60 * 1000); // 为测试,占用了就不放
                        }
                    }
                }
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    }
}

防止死锁产生

为了解决这个问题,我们不使用显示的去锁,我们用信号量去控制.
信号量可以控制资源能被多少线程访问,这里我们指定只能被一个线程访问,就做到了类似锁住.而信号量可以指定去获取的超时时间,我们可以根据这个超时时间,去做一个额外处理.
对于无法成功获取的情况,一般就是重复尝试,或指定尝试的次数,也可以马上退出.

import java.util.Date;
import java.util.concurrent.Semaphore;
import java.util.concurrent.TimeUnit;
 
public class UnLockTest {
   public static String obj1 = "obj1";
   public static final Semaphore a1 = new Semaphore(1);
   public static String obj2 = "obj2";
   public static final Semaphore a2 = new Semaphore(1);
 
   public static void main(String[] args) {
      LockAa la = new LockAa();
      new Thread(la).start();
      LockBb lb = new LockBb();
      new Thread(lb).start();
   }
}
class LockAa implements Runnable {
   public void run() {
      try {
         System.out.println(new Date().toString() + " LockA 开始执行");
         while (true) {
            if (UnLockTest.a1.tryAcquire(1, TimeUnit.SECONDS)) {
               System.out.println(new Date().toString() + " LockA 锁住 obj1");
               if (UnLockTest.a2.tryAcquire(1, TimeUnit.SECONDS)) {
                  System.out.println(new Date().toString() + " LockA 锁住 obj2");
                  Thread.sleep(60 * 1000); // do something
               }else{
                  System.out.println(new Date().toString() + "LockA 锁 obj2 失败");
               }
            }else{
               System.out.println(new Date().toString() + "LockA 锁 obj1 失败");
            }
            UnLockTest.a1.release(); // 释放
            UnLockTest.a2.release();
            Thread.sleep(1000); // 马上进行尝试,现实情况下do something是不确定的
         }
      } catch (Exception e) {
         e.printStackTrace();
      }
   }
}
class LockBb implements Runnable {
   public void run() {
      try {
         System.out.println(new Date().toString() + " LockB 开始执行");
         while (true) {
            if (UnLockTest.a2.tryAcquire(1, TimeUnit.SECONDS)) {
               System.out.println(new Date().toString() + " LockB 锁住 obj2");
               if (UnLockTest.a1.tryAcquire(1, TimeUnit.SECONDS)) {
                  System.out.println(new Date().toString() + " LockB 锁住 obj1");
                  Thread.sleep(60 * 1000); // do something
               }else{
                  System.out.println(new Date().toString() + "LockB 锁 obj1 失败");
               }
            }else{
               System.out.println(new Date().toString() + "LockB 锁 obj2 失败");
            }
            UnLockTest.a1.release(); // 释放
            UnLockTest.a2.release();
            Thread.sleep(10 * 1000); // 这里只是为了演示,所以tryAcquire只用1秒,而且B要给A让出能执行的时间,否则两个永远是死锁
         }
      } catch (Exception e) {
         e.printStackTrace();
      }
   }
}
Tue May 05 10:59:13 CST 2015 LockA 开始执行
Tue May 05 10:59:13 CST 2015 LockB 开始执行
Tue May 05 10:59:13 CST 2015 LockB 锁住 obj2
Tue May 05 10:59:13 CST 2015 LockA 锁住 obj1
Tue May 05 10:59:14 CST 2015LockB 锁 obj1 失败
Tue May 05 10:59:14 CST 2015LockA 锁 obj2 失败
Tue May 05 10:59:15 CST 2015 LockA 锁住 obj1
Tue May 05 10:59:15 CST 2015 LockA 锁住 obj2


标签:obj1,LockA,产生,避免,println,死锁,obj2,Date,new
From: https://blog.51cto.com/u_11797608/6404266

相关文章

  • iostat相关参数说明——await:平均每次设备I/O操作的等待时间 (毫秒),如果%util接近 100
    iostat是I/Ostatistics(输入/输出统计)的缩写,iostat工具将对系统的磁盘操作活动进行监视。它的特点是汇报磁盘活动统计情况,同时也会汇报出CPU使用情况。同vmstat一样,iostat也有一个弱点,就是它不能对某个进程进行深入分析,仅对系统的整体情况进行分析。iostat的语法如下:iostat[......
  • 猪场高温跳闸致5千头猪死亡!物联网技术推广能否避免重演?
    近日高温不断加剧,在这种情况下,特别是那些需要大量能源消耗的场所,也面临着巨大的挑战。据报道,近日在江苏南通的一家养猪场,由于夜间跳闸,养猪场内空气不流通,导致5000头猪在高温下被闷死。由于猪价低,老板没有请人值夜班,直到第二天早上才发现情况不对,估计老板损失近千万!随着物联网技术在......
  • Java并发(八)----使用线程避免cpu占用100%
    1、sleep实现在没有利用cpu来计算时,不要让while(true)空转浪费cpu,这时可以使用yield或sleep来让出cpu的使用权给其他程序while(true){  try{ Thread.sleep(50); }catch(InterruptedExceptione){    e.printStackTrace(); }......
  • 并发中致命的死锁
    本文首发自「慕课网」,想了解更多IT干货内容,程序员圈内热闻,欢迎关注"慕课网"或慕课网公众号!作者:王军伟Tech||慕课网讲师1.前言本文内容主要是对死锁进行深入的讲解,具体内容点如下:理解线程的上下文切换,这是本节的辅助基础内容,从概念层面进行理解即可;了解什么是线程死锁,在并发编程......
  • EFF-POST:如何避免低级错误
    晒张图(一个非常离谱的错误)常见问题数组/值域/数据类型没有开到给定的范围(通常是因为对范围没有估计/估计错误而非不小心)卡精度(有多种应对方法,如divisible,fraction)变量名出问题(集中在n和m搞混这种问题)边界问题(DP转移,etc.)多测没清空(纯SB)注意这都是平时做题时突出的......
  • JS垃圾回收——和其他语言一样,JavaScript 的 GC 策略也无法避免一个问题:GC 时,停止响应
    JavaScript内存管理&垃圾回收机制标记清除js中最常用的垃圾回收方式就是标记清除。当变量进入环境时,例如,在函数中声明一个变量,就将这个而变量标记为“进入环境”。从逻辑上讲,永远不能释放进入环境的变量所占用的内存,因为只要执行流进入相应的环境,就可能会用到它们。而当变量离......
  • 【外汇天眼】外汇交易中的智慧:避免过早止损的关键策略!
    外汇交易市场的波动性和风险使得止损成为交易者保护自身资金的重要手段。然而,过早止损可能会导致交易者错失潜在盈利机会。本文将介绍一些关键策略,帮助交易者避免过早止损,并特别介绍波动点止损法,以提高交易效果。1.设定合理的止损水平:合理设置止损水平是避免过早止损的第一步。交......
  • 服务质量_QOS【管制和拥塞避免机制】
    服务质量_QOS【标记和队列】:https://www.cnblogs.com/good-study/p/16160592.html1.1区分服务模型配置步骤:分类classfication/标记Marking管制Policing/整形Shaping      限速拥塞避免机制REDWRED  防止尾丢弃队列Queuing:PQ、CQ、WFQ、FIFO、CB、WFQ......
  • 基于FPGA的LFSR16位伪随机数产生算法实现,可以配置不同的随机数种子和改生成多项式,包
    1.算法仿真效果vivado2019.2仿真结果如下:2.算法涉及理论知识概要LFSR(线性反馈移位寄存器)提供了一种在微控制器上快速生成非序列数字列表的简单方法。生成伪随机数只需要右移操作和XOR操作。LFSR完全由其多项式指定。例如,6千-次多项式与每个项存在用方程x表示6+x5+x4+x3......
  • gdb调试c++多线程死锁问题初步
    https://blog.csdn.net/zsiming/article/details/126695393 总结:psaux|grepfilename //找出进程IDtop-HpPID //列出进程号为PID下的所有线程gdbatattchPID //用gdb调试正在运行的进程(进程号为PID)(需要sudo权限)threadapplyallbt //这里涉及2个命令:thr......