iis服务器助手广告广告
返回顶部
首页 > 资讯 > 后端开发 > Python >java调用process线程阻塞问题的解决
  • 880
分享到

java调用process线程阻塞问题的解决

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

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

摘要

java调用process线程阻塞问题 项目需求中涉及java调用.bat文件进行图像处理,先直接上简略版程序 public void draw(){ //调用b

java调用process线程阻塞问题

项目需求中涉及java调用.bat文件进行图像处理,先直接上简略版程序


public void draw(){
        //调用bat脚本进行图像处理
        Process process = null;
        InputStream in = null;
        try {
            process = Runtime.getRuntime().exec("startup.bat");
            //输出测试
//            in = process.getInputStream();
//            String line;
//            BufferedReader br = new BufferedReader(new InputStreamReader(in));
//            while ((line = br.readLine()) != null) {
//                System.out.println(line);
//            }
            //等待
            process.waitFor();
        } catch (Exception e) {
        } finally {
            process.destroy();
        }
    }

JAVA使用遇到的问题描述

一般需要调用系统命令时,大部分人第一反应肯定是使用Runtime.getRuntime().exec(command)返回一个process对象,再调用process.waitFor()来等待命令执行结束,获取执行结果。

调试的时候发现异常现象,process.waitFor();一直没有结束,导致线程阻塞再次,强行关闭程序后,发现图像处理只进行了一部分。

根据现象并查看了jdk的帮助文档,如下

如有必要,一直要等到由该 Process 对象表示的进程已经终止。如果已终止该子进程,此方法立即返回。但是直接调用这个方法会导致当前线程阻塞,直到退出子进程。

对此JDK文档上还有如此解释:因为本地的系统对标准输入和输出所提供的缓冲池有效,所以错误的对标准输出快速的写入何从标准输入快速的读入都有可能造成子进程的阻塞,甚至死

Process执行逻辑

* 主进程中调用Runtime.exec会创建一个子进程,用于执行脚本。子进程创建后会和主进程分别独立运行。

* 创建的子进程没有自己的终端或控制台。它的所有标准 io(即 stdin、stdout 和 stderr)操作都将通过三个流 (getOutputStream()、getInputStream() 和 getErrorStream()) 重定向到父进程。父进程使用这些流来提供到子进程的输入和获得从子进程的输出。

* 这时候子进程不断向主进程发生数据,而主进程调用Process.waitfor后已挂起。当前子进程和主进程之间的缓冲区塞满后,子进程不能继续写数据,然后也会挂起。

* 这样子进程等待主进程读取数据,主进程等待子进程结束,两个进程相互等待,最终导致死锁。

解决方法:

在waitFor()之前,利用单独两个线程,分别处理process的getInputStream()和getErrorSteam(),防止缓冲区被撑满,导致阻塞;

修改后代码


public class test {
    public void draw(){
        //调用bat脚本进行图像处理
        Process process = null;
        InputStream in = null;
        try {
            process = Runtime.getRuntime().exec("startup.bat");
            //输出测试
//            in = process.getInputStream();
//            String line;
//            BufferedReader br = new BufferedReader(new InputStreamReader(in));
//            while ((line = br.readLine()) != null) {
//                System.out.println(line);
//            }
            //新启两个线程
            new DealProcessSream(process.getInputStream()).start();
            new DealProcessSream(process.getErrorStream()).start();
            process.waitFor();
        } catch (Exception e) {
        } finally {
            process.destroy();
        }
    }
}

public class DealProcessSream extends Thread {
    private InputStream inputStream;
    public DealProcessSream(InputStream inputStream) {
        this.inputStream = inputStream;
    }
    public void run() {
        InputStreamReader inputStreamReader = null;
        BufferedReader br = null;
        try {
            inputStreamReader = new InputStreamReader(
                    inputStream);
            br = new BufferedReader(inputStreamReader);
            // 打印信息
//            String line = null;
//            while ((line = br.readLine()) != null) {
//                System.out.println(line);
//            }
            // 不打印信息
           while (br.readLine() != null);
        } catch (IOException ioe) {
            ioe.printStackTrace();
        }finally {
            try {
                br.close();
                inputStreamReader.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
}

Process对象.waitFor()的阻塞问题(坑)

有时需要在程序中调用可执行程序或脚本命令:


Process process = Runtime.getRuntime().exec(shPath);
int exitCode = process .waitFor();

Runtime.getRuntime()返回当前应用程序的Runtime对象,该对象的exec()方法指示Java虚拟机创建一个子进程执行指定的可执行程序,

并返回与该子进程对应的Process对象实例。通过Process可以控制该子进程的执行或获取该子进程的信息。

它的所有标准io(即stdin,stdout,stderr)操作都将通过三个流(getOutputStream(),getInputStream(),getErrorStream())重定向到父进程。

父进程使用这些流来提供到子进程的输入和获得从子进程的输出。因为有些本机平台仅针对标准输入和输出流提供有限的缓冲区大小,如果读

写子进程的输出流或输入流出现失败,则可能导致子进程阻塞,甚至产生死锁。(如果程序不断在向标准输出流和标准错误流写数据,而JVM不读取的话,当缓冲区满之后将无法继续写入数据,最终造成阻塞在waifor()这里。)

process .getErrorStream():获得子进程的错误输出流

process .getInputStream():获得子进程的普通输出流

简单示例:


Process shellProcess = null;
    try {
 
      shellProcess = Runtime.getRuntime().exec(shPath);
      shellErrorResultReader = new BufferedReader(new InputStreamReader(shellProcess.getErrorStream()));
      shellInfoResultReader =  new BufferedReader(new InputStreamReader(shellProcess.getInputStream()));
      String infoLine;
      while ((infoLine = shellInfoResultReader.readLine()) != null) {
        logger.info("脚本文件执行信息:{}", infoLine);
      }
      String errorLine;
      while ((errorLine = shellErrorResultReader.readLine()) != null) {
        logger.warn("脚本文件执行信息:{}", errorLine);
      }
      // 等待程序执行结束并输出状态
      exitCode = shellProcess.waitFor();
      if (0 == exitCode) {
        logger.info("脚本文件执行成功:" + exitCode);
      } else {
        logger.error("脚本文件执行失败:" + exitCode);
      }
    } catch (Exception e) {
      logger.error("shell脚本执行错误", e);
    } finally {
      if (null != shellInfoResultReader) {
        try {
          shellInfoResultReader.close();
        } catch (IOException e) {
          logger.error("流文件关闭异常:", e);
        }
      }
      if (null != shellErrorResultReader) {
        try {
          shellErrorResultReader.close();
        } catch (IOException e) {
          logger.error("流文件关闭异常:", e);
        }
      }
      if (null != shellProcess) {
        shellProcess.destroy();
      }
}

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

--结束END--

本文标题: java调用process线程阻塞问题的解决

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

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

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

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

下载Word文档
猜你喜欢
  • java调用process线程阻塞问题的解决
    java调用process线程阻塞问题 项目需求中涉及java调用.bat文件进行图像处理,先直接上简略版程序 public void draw(){ //调用b...
    99+
    2024-04-02
  • 如何解决java调用process线程阻塞的问题
    这篇文章将为大家详细讲解有关 如何解决java调用process线程阻塞的问题,小编觉得挺实用的,因此分享给大家做个参考,希望大家阅读完这篇文章后可以有所收获。java调用process线程阻塞问题项目需求中涉及java调用.bat文件进行...
    99+
    2023-06-15
  • 基于Process#waitFor()阻塞问题的解决
    目录Process#waitFor()阻塞问题Process.waitFor()导致主线程堵塞Process#waitFor()阻塞问题 有时需要在程序中调用可执行程序或脚本命令: ...
    99+
    2024-04-02
  • 解决SecureRandom.getInstanceStrong()引发的线程阻塞问题
    目录1. 背景介绍2. 现象展示2.1 windows7下运行结果2.2 centos7下运行结果3. 现象分析3.1 linux阻塞分析3.2 windows下运行结果分析4. 结...
    99+
    2024-04-02
  • 如何解决基于Process#waitFor()阻塞问题
    这篇文章主要介绍了如何解决基于Process#waitFor()阻塞问题,具有一定借鉴价值,感兴趣的朋友可以参考下,希望大家阅读完这篇文章之后大有收获,下面让小编带着大家一起了解一下。Process#waitFor()阻塞问题有时需要在程序...
    99+
    2023-06-22
  • java线程阻塞怎么解决
    在Java中,线程阻塞可以通过以下几种方式解决:1. 使用synchronized关键字:通过在代码块或方法上加上synchroni...
    99+
    2023-08-18
    java
  • 解决Process.getInputStream()阻塞的问题
    Process.getInputStream()阻塞问题 Java中 Runtime.getInstance().exec (String cmd) 或者 new Proc...
    99+
    2024-04-02
  • 解决Java中socket使用getInputStream()阻塞问题
    目录socket使用getInputStream()阻塞用线程解决Socket的getInputStream阻塞1.背景2.问题3.原因4.解决办法5.Socket通信注意事项soc...
    99+
    2024-04-02
  • 解决Go语言Websocket应用程序中的线程阻塞问题
    解决Go语言Websocket应用程序中的线程阻塞问题在开发Web应用程序时,使用Websocket是一种非常常见和流行的方式。它可以建立持久的连接,并在服务器和客户端之间实时通信。然而,有时候我们可能会遇到线程阻塞的问题,这会导致应用程序...
    99+
    2023-12-14
    Go语言 websocket 线程阻塞问题
  • Java Process与Runtime()的使用及调用cmd命令阻塞的解决方案
    Java Process与Runtime()使用 java调用cmd执行bat文件有时会出现卡死的现象,当时感觉很迷惑,后来查资料,本来一般都是这样来调用程序并获取进程的输出流的,但...
    99+
    2024-04-02
  • 如何解决Process.getInputStream()阻塞的问题
    这篇文章主要介绍了如何解决Process.getInputStream()阻塞的问题,具有一定借鉴价值,感兴趣的朋友可以参考下,希望大家阅读完这篇文章之后大有收获,下面让小编带着大家一起了解一下。Process.getInputStream...
    99+
    2023-06-15
  • weblogic线程阻塞如何解决
    WebLogic线程阻塞问题可以通过以下方法来解决:1. 检查应用程序代码:检查应用程序的代码,确保没有出现死循环、无限循环或其他无...
    99+
    2023-09-01
    weblogic
  • Java中socket使用getInputStream()阻塞问题怎么解决
    这篇文章主要介绍“Java中socket使用getInputStream()阻塞问题怎么解决”,在日常操作中,相信很多人在Java中socket使用getInputStream()阻塞问题怎么解决问题上存在疑惑,小编查阅了各式资料,整理出简...
    99+
    2023-06-22
  • 如何解决jQuery同步Ajax带来的UI线程阻塞问题
    这篇文章主要介绍如何解决jQuery同步Ajax带来的UI线程阻塞问题,文中介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们一定要看完!事情起因是这样的,因为页面上有多个相似的异步请求动作,本着提高代码...
    99+
    2024-04-02
  • 如何解决TCP socket的阻塞问题
    目录解决TCP socket的阻塞问题在异常处理程序当中退出socket连接TCP连接阻塞的监控和处理我们整理出符合该类异常的特征如下如何查看一个连接的创建时间解决TCP socke...
    99+
    2024-04-02
  • 怎么解决TCP socket的阻塞问题
    小编给大家分享一下怎么解决TCP socket的阻塞问题,相信大部分人都还不怎么了解,因此分享这篇文章给大家参考一下,希望大家阅读完这篇文章后大有收获,下面让我们一起去了解一下吧!解决TCP socket的阻塞问题大家知道,tcp...
    99+
    2023-06-22
  • 使用Runtime调用Process.waitfor导致的阻塞问题
    目录1. 关于Runtime类的小知识2. Runtime的几个重要的重载方法3. Runtime的使用方式4. 卡死原因5. 解决方案6. Runtime最优雅的调用方式1. 关于...
    99+
    2024-04-02
  • quartz任务阻塞问题怎么解决
    解决Quartz任务阻塞问题的方法有以下几种:1. 增加线程池大小:默认情况下,Quartz使用一个线程执行任务。如果任务较多或者任...
    99+
    2023-09-18
    quartz
  • Android中bindservice阻塞问题怎么解决
    在Android中,绑定服务(bindService)是一种异步操作,它不会阻塞主线程。但有时候可能会出现与服务通信的操作阻塞了UI...
    99+
    2024-02-29
    Android
  • Java Socket上的Read操作阻塞问题详解
    目录Socket上的Read操作阻塞问题从Socket上读取对端发过来的数据一般有两种方法总结一下,有这么几个方法Socket编程---read方法阻塞问题Socket上的Read操...
    99+
    2024-04-02
软考高级职称资格查询
编程网,编程工程师的家园,是目前国内优秀的开源技术社区之一,形成了由开源软件库、代码分享、资讯、协作翻译、讨论区和博客等几大频道内容,为IT开发者提供了一个发现、使用、并交流开源技术的平台。
  • 官方手机版

  • 微信公众号

  • 商务合作