ICode9

精准搜索请尝试: 精确搜索
首页 > 编程语言> 文章详细

java-如何使用带有参数的exitValue()?

2019-10-10 00:05:46  阅读:426  来源: 互联网

标签:processbuilder java nonblocking


一篇很好的文章(当Runtime.exec()不会)说:您唯一可能使用exitValue()而不是waitFor()的时间是当您不希望您的程序阻塞在某个外部进程上等待时,可能永远不会完成.与其使用waitFor()方法,不如将一个名为waitFor的布尔参数传递给exitValue()方法,以确定当前线程是否应等待.布尔值会更有益,因为exitValue()是此方法的更合适的名称,并且两个方法不必在不同的条件下执行相同的功能.这种简单的条件判别是输入参数的领域.

我的情况完全相同,我的系统调用将启动一个进程,该进程将一直运行,直到用户决定杀死它为止.如果我使用'(process.waitFor()== 0)’,它将在此阻止程序,因为进程将无法完成.以上文章的作者建议exitValue()可以与“ waitFor”参数一起使用.有人尝试过吗?任何示例都将有所帮助.

码:

//启动ProcessBuilder,“ str”包含命令

ProcessBuilder pbuilder = new ProcessBuilder(str);
pbuilder.directory(new File("/root/workspace/Project1"));
pbuilder.redirectErrorStream(true);
Process prcs = pbuilder.start();
AForm.execStatustext.append("\n=> Process is:" + prcs);

// Read output
StringBuilder out = new StringBuilder();
BufferedReader bfrd = new BufferedReader(new InputStreamReader(process.getInputStream()));
String current_line = null, previous_line = null;
while ((current_line = bfrd.readLine()) != null) {
    if (!line.equals(previous_line)) {
        previous_line = current_line;
        out.append(current_line).append('\n');
        //System.out.println(line);
    }
}
//process.getInputStream().close();
// Send 'Enter' keystroke through BufferedWriter to get control back
BufferedWriter bfrout = new BufferedWriter(new OutputStreamWriter(prcs.getOutputStream()));
bfrout.write("\\r");
bfrout.newLine();
bfrout.flush();
bfrout.write("\\r");
bfrout.newLine();
bfrout.flush();
//process.getOutputStream().close();*/

if (prcs.waitFor() == 0)
    System.out.println("Commands executed successfully");
System.exit(0); 

解决方法:

在主线程中使用waitFor之前,请创建另一个线程(子代),并在此新线程中为终止情况构造逻辑.例如,等待10秒.
如果满足条件,则从子线程ant中断主线程,并在主线程上处理以下逻辑.

以下代码创建一个子线程来调用该进程,主线程执行其工作,直到子进程成功完成.

    import java.io.IOException;


    public class TestExecution {

        public boolean myProcessState = false;

        class MyProcess implements Runnable {

            public void run() {
                //------
                Process process;
                try {
                    process = Runtime.getRuntime().exec("your command");
                    process.waitFor();
                    int processExitValue = process.exitValue();

                    if(processExitValue == 0) {
                        myProcessState = true;
                    }

                } catch (IOException e) {
                    e.printStackTrace();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }

            }

        }

        public void doMyWork() {

            MyProcess myProcess = new MyProcess();

            Thread myProcessExecuter = new Thread(myProcess);
            myProcessExecuter.start();

            while(!myProcessState) {
                // do your job until the process exits with success
            }
        }

        public static void main(String[] args) {

            TestExecution testExecution = new TestExecution();
            testExecution.doMyWork();
        }
    }

标签:processbuilder,java,nonblocking
来源: https://codeday.me/bug/20191009/1882749.html

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

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

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

ICode9版权所有