iis服务器助手广告广告
返回顶部
首页 > 资讯 > 后端开发 > Python >关于Process的waitFor死锁问题及解决方案
  • 932
分享到

关于Process的waitFor死锁问题及解决方案

2024-04-02 19:04:59 932人浏览 薄情痞子

Python 官方文档:入门教程 => 点击学习

摘要

目录Process的waitFor死锁问题1、发现问题2、原因查找3、造成死锁原理图问题代码解决方案Java中死锁的简单例子及其避免我们来看一个死锁的简单例子那么要怎么预防死锁呢?P

Process的waitFor死锁问题

1、发现问题

在实际开发中,进行文件操作时,使用Process对文件进行解压操作,程序执行过程中会出现一直卡在那的问题。

2、原因查找

问题在缓冲区这个地方:可执行程序的标准输出比较多,而运行窗口的标准缓冲区不够大,所以发生阻塞。接着来分析缓冲区,当Runtime对象调用exec(cmd)后,JVM会启动一个子进程,该进程会与JVM进程建立三个管道连接:标准输入,标准输出和标准错误流。假设该程序不断在向标准输出流和标准错误流写数据,而JVM不读取的话,当缓冲区满之后将无法继续写入数据,最终造成阻塞在waitfor()这里。

程序运行过程产生等待分析:

(1)、当我们使用Runtime.exec执行命令时,JAVA的线程会创建一个子进程,用于执行命令,而且子进程和JAVA线程会分别独立运行。

(2)、JAVA线程需要等待命令的执行完成,对命令的日志和返回值进行处理,所以在JAVA线程中调用Process.waitFor挂起来等待子进程完成。

(3)、子线程执行时,不断的打印日志信息,我们通过Process.getInputStream和Process.getErrorStream进行获取正常输出日志和错误日志进行处理,也即是读数据。

(4)、这个时候子进程不断的向JAVA线程写入数据,而JAVA线程调用Process.waitFor后已经阻塞挂起,而子进程在不断的向JAVA线程进行写入数据,当我们的Process.getInputStream的buffer缓冲区被写满,JAVA线程依然挂起并未消费buffer中的数据,导致子进程无法继续向buffer缓冲区中继续写入数据,导致子进程也挂起。

(5)、这个时候JAVA线程和子进程都处于挂起的状态,JAVA线程等待子进程的结束,子进程等待JAVA线程对buffer缓冲区中的数据进行消费。两者在相互等待导致死锁。

3、造成死锁原理图

在这里插入图片描述

问题代码


public static String cmd(String cmd) throws InterruptedException  {
        try {
                // 使用Runtime来执行command,生成Process对象
                Process process = Runtime.getRuntime().exec(
                        new String[] { "/bin/sh", "-c", cmd });
                int exitCode = process.waitFor();
                // 取得命令结果的输出流
                InputStream is = process.getInputStream();
                // 用一个读输出流类去读
                InputStreamReader isr = new InputStreamReader(is);
                // 用缓冲器读行
                BufferedReader br = new BufferedReader(isr);
                String line = null;
                StringBuilder sb = new StringBuilder();
                while ((line = br.readLine()) != null) {
                    sb.append(line);
                }
                is.close();
                isr.close();
                br.close();
                
                return sb.toString();
            } catch (java.lang.NullPointerException e) {
            	
            	throw new BaseException(e);
            } catch (java.io.IOException e) {
            	throw new BaseException(e);
            }
            return null;
    }

这段代码会产生死锁的原因是, BufferedReader br = new BufferedReader(isr);放在了process.waitFor();之后执行,并不能有效的清空缓冲区,还是会造成缓冲区满,造成阻塞。

解决方案

知道问题原因就号解决了


public static String callCmd(String cmd) throws InterruptedException  {
         Process process = null;
         BufferedReader nORMalReader = null;
         BufferedReader errorReader = null;
         try {          
                process = Runtime.getRuntime().exec(
                        new String[] { "/bin/sh", "-c", cmd });
                
                normalReader = new BufferedReader(new InputStreamReader(process.getInputStream()));
                errorReader = new  BufferedReader(new  InputStreamReader(process.getErrorStream()));
                String line = null;
                StringBuilder sb = new StringBuilder();
                while ((line = normalReader.readLine()) != null) {
                    sb.append(line);
                }
                String errorLine;
                while ((errorLine = errorReader.readLine()) != null) {
                    logger.warn("脚本文件执行信息ErrorStream:{}", errorLine);
                }
                // 等待程序执行结束并输出状态
                int exitCode = process.waitFor();
                if (0 == exitCode) {
                    logger.info("脚本文件执行成功!");
                } else {
                    logger.error("脚本文件执行失败:{}",cmd);
                    throw new BaseException("脚本文件执行失败:"+cmd);
                }
                return sb.toString();
          } catch (java.lang.NullPointerException e) {
                throw new BaseException(e);
          } catch (java.io.IOException e) {
                throw new BaseException(e);
          }finally{
                if (null != normalReader) {
                    try {
                        normalReader.close();
                    } catch (IOException e) {
                        logger.error("流文件关闭异常:", e);
                    }
                }
                if (null != errorReader) {
                    try {
                        errorReader.close();
                    } catch (IOException e) {
                        logger.error("流文件关闭异常:", e);
                    }
                }
                if (null != process) {
                    process.destroy();
                }
         }
    }

Java中死锁的简单例子及其避免

死锁:当一个线程永远地持有一个锁,并且其他线程都尝试获得这个锁时,那么它们将永远被阻塞。

比如,线程1已经持有了A锁并想要获得B锁的同时,线程2持有B锁并尝试获取A锁,那么这两个线程将永远地等待下去。

我们来看一个死锁的简单例子


public class DeadLockTest
{
    private static Object A = new Object(), B = new Object();
    public static void main(String[] args)
    {
        new Thread(() -> {
            System.out.println("线程1开始执行...");
            synchronized (A)
            {
                try
                {
                    System.out.println("线程1拿到A锁");
                    //休眠两秒让线程2有时间拿到B锁
                    Thread.sleep(2000);
                } catch (Exception e)
                {
                    e.printStackTrace();
                }
                synchronized (B)
                {
                    System.out.println("线程1拿到B锁");
                }
            }
        }).start();
        new Thread(() -> {
            System.out.println("线程2开始执行...");
            synchronized (B)
            {
                try
                {
                    System.out.println("线程2拿到B锁");
                    //休眠两秒让线程1有时间拿到A锁
                    Thread.sleep(2000);
                } catch (Exception e)
                {
                    e.printStackTrace();
                }
                synchronized (A)
                {
                    System.out.println("线程2拿到A锁");
                }
            }
        }).start();
    }
}

运行结果:

从运行结果可看到,线程1拿到了A锁,并尝试去获取B锁,与此同时线程2拿到了B锁并尝试去获取A锁,此时线程1和线程2就陷入了无限的等待,形成死锁。

那么要怎么预防死锁呢?

下面介绍几个常见方法:

1、避免一个线程同时获取多个锁

2、避免一个线程在锁内同时占用多个资源,尽量保证每个锁只占用一个资源

3、尝试使用定时锁,使用lock.tryLock来代替使用内置锁。

以上为个人经验,希望能给大家一个参考,也希望大家多多支持编程网。

--结束END--

本文标题: 关于Process的waitFor死锁问题及解决方案

本文链接: https://www.lsjlt.com/news/159816.html(转载时请注明来源链接)

有问题或投稿请发送至: 邮箱/279061341@qq.com    QQ/279061341

本篇文章演示代码以及资料文档资料下载

下载Word文档到电脑,方便收藏和打印~

下载Word文档
猜你喜欢
  • 关于Process的waitFor死锁问题及解决方案
    目录Process的waitFor死锁问题1、发现问题2、原因查找3、造成死锁原理图问题代码解决方案Java中死锁的简单例子及其避免我们来看一个死锁的简单例子那么要怎么预防死锁呢?P...
    99+
    2024-04-02
  • Process的waitFor死锁问题如何解决
    本篇内容主要讲解“Process的waitFor死锁问题如何解决”,感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷,实用性强。下面就让小编来带大家学习“Process的waitFor死锁问题如何解决”吧!Process的waitFor死...
    99+
    2023-06-22
  • 基于Process#waitFor()阻塞问题的解决
    目录Process#waitFor()阻塞问题Process.waitFor()导致主线程堵塞Process#waitFor()阻塞问题 有时需要在程序中调用可执行程序或脚本命令: ...
    99+
    2024-04-02
  • 如何解决基于Process#waitFor()阻塞问题
    这篇文章主要介绍了如何解决基于Process#waitFor()阻塞问题,具有一定借鉴价值,感兴趣的朋友可以参考下,希望大家阅读完这篇文章之后大有收获,下面让小编带着大家一起了解一下。Process#waitFor()阻塞问题有时需要在程序...
    99+
    2023-06-22
  • 【mysql】mysql死锁问题解决方案
    mysql死锁问题解决方案 查询出是被哪个进程给锁住了为什么会产生死锁日志内容:日志解析:找到问题: 解决方案 查询出是被哪个进程给锁住了 执行sql: select ...
    99+
    2023-09-23
    mysql adb 数据库
  • MySQL死锁问题的分析及解决方法
    这篇文章主要讲解了“MySQL死锁问题的分析及解决方法”,文中的讲解内容简单清晰,易于学习与理解,下面请大家跟着小编的思路慢慢深入,一起来研究和学习“MySQL死锁问题的分析及解决方法”吧!MySQL死锁问...
    99+
    2024-04-02
  • Java中的死锁及其解决方案
    Java中的死锁及其解决方案 在Java中,锁是很常见的一个工具,常见的用法就是在高并发场景下保证线程安全,但是使用不当也会造成死锁,给我们带来一些不必要的麻烦,本文分析死锁及其产生原因,并作出相应的解决方案。 死锁产生的四个必要条件 ...
    99+
    2023-09-04
    java Powered by 金山文档
  • MySQL - 死锁的产生及解决方案
    MySQL - 死锁的产生及解决方案 1. 死锁与产生死锁的四个必要条件1.1 什么是死锁1.2 死锁产生的4个必要条件 2. 死锁案例2.1 表锁死锁2.2 行锁死锁2.3 共享锁转换为排他锁 3. 死锁排查4. 实例分析...
    99+
    2023-08-17
    mysql 数据库
  • 关于spring循环依赖问题及解决方案
    目录一、三种循环依赖的情况比如几个Bean之间的互相引用 甚至自己“循环”依赖自己二、解决方案如何获取依赖三、解决循环依赖必须要三级缓存吗结论四、无...
    99+
    2024-04-02
  • 关于@Transactional事务表被锁的问题及解决
    目录@Transactional事务表被锁只读事务读写事务@Transactional注解乱用引发的异常@Transactional事务表被锁 通常在执行查询的时候,进行更新。数据量...
    99+
    2024-04-02
  • 关于Fragment already added问题的解决方案
    目录Fragment already added问题解决问题方法java.lang.IllegalStateException: Fragment already added 异常处...
    99+
    2024-04-02
  • 常见的MySQL锁问题及其解决方案
    MySQL 锁的常见问题与解决方案MySQL 是一种常用的关系型数据库管理系统,它使用锁来实现并发控制,保证数据的一致性和完整性。然而,MySQL 锁的使用也会带来一些问题。本文将介绍一些常见的 MySQL 锁的问题,并提供相应的解决方案。...
    99+
    2023-12-21
    解决方案 常见问题 MySQL
  • 关于MySQL死锁问题的深入分析
    前言 如果我们的业务处在一个非常初级的阶段,并发程度比较低,那么我们可以几年都遇不到一次死锁问题的发生,反之,我们业务的并发程度非常高,那么时不时爆出的死锁问题肯定让我们非常挠头。不过在死锁问题发生时,很多...
    99+
    2024-04-02
  • 关于RsaPublicKeynotFind的问题及解决
    目录Rsa Public Key not Find的问题问题描述解决方案Navicat15注册机出现 rsa public key not foundRsa Public Key n...
    99+
    2024-04-02
  • 关于Controller层和Service层的类报错问题及解决方案
    目录Controller层和Service层的类报错Controller层和Service层的作用1.在controller和service里都写那些代码?2.在整个项目中什么时候加...
    99+
    2024-04-02
  • 在python中解决死锁的问题
    1.添加超时时间: fromthreading import Thread, Lock importtime mutex1= Lock() # 创建一个互斥锁 mutex2=...
    99+
    2024-04-02
  • 如何解决Task.Result就死锁的问题
    如何解决Task.Result就死锁的问题,很多新手对此不是很清楚,为了帮助大家解决这个难题,下面小编将为大家详细讲解,有这方面需求的人可以来学习下,希望你能有所收获。一、背景1. 讲故事前些天把 .NET...
    99+
    2024-04-02
  • 关于Assert.assertEquals报错的问题及解决
    目录前提(也是主要问题)用testCompile导入junit4.12在IDEA的自动提示下点进去Assert看了下发现后面看了才知道导错包本来以为是junit依赖没导进来里面Ass...
    99+
    2024-04-02
  • Go 语言中的死锁问题解决
    目录死锁如何避免死锁死锁代码死锁 死锁的4个条件 不可剥夺 线程已经获得的资源,在未使用完之前,不能被其他线程剥夺,只能在使用完后自己释放。 请求保持 线程...
    99+
    2024-04-02
  • 关于springboot整合swagger问题及解决方法
    目录一.前言二.整合jsp1.pom引入2.配置文件application.properties3.前端代码目录4.运行效果 三.整合swagger1.pom引入2.swa...
    99+
    2024-04-02
软考高级职称资格查询
编程网,编程工程师的家园,是目前国内优秀的开源技术社区之一,形成了由开源软件库、代码分享、资讯、协作翻译、讨论区和博客等几大频道内容,为IT开发者提供了一个发现、使用、并交流开源技术的平台。
  • 官方手机版

  • 微信公众号

  • 商务合作