ICode9

精准搜索请尝试: 精确搜索
首页 > 其他分享> 文章详细

.waitFor()卡死

2021-10-14 09:06:49  阅读:126  来源: 互联网

标签:args JAVA Process waitFor 线程 缓冲区 new 卡死


二、查找原因
经过查找资料了解到:Process.waitFor可能导致死锁?
因为本地的系统对标准输入和输出所提供的缓冲池有限,所以错误的对标准输出快速的写入和从标准输入快速的读入都有可能造成子进程死锁。问题的关键在缓冲区这个地方:可执行程序的标准输出比较多,而运行窗口的标准缓冲区不够大,所以发生阻塞。接着来分析缓冲区,当Runtime对象调用exec(cmd)后,JVM会启动一个子进程,该进程会与JVM进程建立三个管道连接:标准输入,标准输出和标准错误流。假设该程序不断在向标准输出流和标准错误流写数据,而JVM不读取的话,当缓冲区满之后将无法继续写入数据,最终造成阻塞在waitfor()这里。

需要注意读取程序的stdout和stderr都是阻塞的操作,这意味着必须在两个线程里分别读取,而不是在一个线程里一次读取,否则还是有可能出现阻塞的情况:比如先读取stdout再读取stderr,如果程序的stderr输出已经填满了缓冲区,程序就会阻塞不继续执行,但是java线程又阻塞在读取stdout上,只有stdout结束了才会去读取stderr。结果就是互相等待着的过程中哦给你程序卡死了

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缓冲区中的数据进行消费。两者在相互等待导致死锁。

死锁原理图

三、解决方案
1.思路
既然是由于buffer缓冲区的数据没有消费导致子进程挂起,那么我们从这里下手。

a. 消费buffer缓冲区中的数据

b. 当JAVA线程调用Process.waitFor后,线程会进行挂起,那我们就使用多线程进行消费数据。

2.正常流程图


3.代码实现
容易出现死锁的旧代码

public static boolean execCommond(String... args) {
    boolean flg = true;
    Runtime run = Runtime.getRuntime();
    try {
        Process p;
        if (args != null && args.length == 1) {
            p = run.exec(args[0]);
        } else {
            p = run.exec(args);
        }
        LoggerUtils.info(CmdExecUtils.class, p.getInputStream() + "....getInputStream..");
        BufferedInputStream in = new BufferedInputStream(p.getInputStream());
        BufferedReader inBr = new BufferedReader(new InputStreamReader(in));
        
        LoggerUtils.info(CmdExecUtils.class, inBr + "....inBr..");
        
        String lineStr;
        while ((lineStr = inBr.readLine()) != null) {
           LoggerUtils.info(CmdExecUtils.class, lineStr );
            System.out.println(lineStr);// 打印输出信息
        }
        if (p.waitFor() != 0) {
            if (p.exitValue() == 1) {
               logger.info("==================================命令执行失败!");
                flg = false;
            }
        }
        inBr.close();
        in.close();
    } catch (Exception e) {
        e.printStackTrace();
        flg = false;
    }
    return flg;
}
解决死锁后的代码:

private static ThreadPoolExecutor executor;
 
static {
    ThreadFactory namedThreadFactory = new ThreadFactoryBuilder()
            .setNameFormat("cmd-pool-%d").build();
    //根据实际情况创建线程池
    executor = new ThreadPoolExecutor(6, 10, 5,
            TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>(1024),
            namedThreadFactory, new ThreadPoolExecutor.AbortPolicy());
}
 
/**
 * 流处理
 * @param stream
 */
private static void clearStream(InputStream stream) {
    //处理buffer的线程
    executor.execute(new Runnable() {
        @Override
        public void run() {
 
            String line = null;
 
            try (BufferedReader in = new BufferedReader(new InputStreamReader(stream));) {
                while ((line = in.readLine()) != null) {
                    LoggerUtils.debug(CmdExecUtils.class,line);
                }
            } catch (IOException e) {
                LoggerUtils.error(CmdExecUtils.class,"exec error : {}", e);
            }
        }
    });
}
 
public static boolean execCommond(String... args) {
    boolean flg = true;
    Runtime run = Runtime.getRuntime();
    try {
        Process p;
        if (args != null && args.length == 1) {
            p = run.exec(args[0]);
        } else {
            p = run.exec(args);
        }
 
        InputStream stream=p.getInputStream();
        LoggerUtils.info(CmdExecUtils.class, stream + "....getInputStream..");
 
        //消费正常日志
        clearStream(stream);
        //消费错误日志
        clearStream(p.getErrorStream());
 
        if (p.waitFor() != 0) {
            if (p.exitValue() == 1) {
                LoggerUtils.info(CmdExecUtils.class,"=============exec=====================命令执行失败!");
                flg = false;
            }
        }
 
    } catch (Exception e) {
        e.printStackTrace();
        flg = false;
    }
    return flg;
}

标签:args,JAVA,Process,waitFor,线程,缓冲区,new,卡死
来源: https://blog.csdn.net/u014161595/article/details/120756641

本站声明: 1. iCode9 技术分享网(下文简称本站)提供的所有内容,仅供技术学习、探讨和分享;
2. 关于本站的所有留言、评论、转载及引用,纯属内容发起人的个人观点,与本站观点和立场无关;
3. 关于本站的所有言论和文字,纯属内容发起人的个人观点,与本站观点和立场无关;
4. 本站文章均是网友提供,不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属;如您发现该文章侵犯了您的权益,可联系我们第一时间进行删除;
5. 本站为非盈利性的个人网站,所有内容不会用来进行牟利,也不会利用任何形式的广告来间接获益,纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

专注分享技术,共同学习,共同进步。侵权联系[81616952@qq.com]

Copyright (C)ICode9.com, All Rights Reserved.

ICode9版权所有