如何将exitValue()与参数一起使用?[英] How to use exitValue() with parameter?

问题描述

一篇非常好的文章(当 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 秒.如果满足条件,则从子线程中中断主线程,并在主线程上处理以下逻辑.

下面的代码创建一个子线程来调用进程,主线程完成它的工作,直到子线程成功完成.

    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();
        }
    }

本文地址:https://www.itbaoku.cn/post/978523.html