等待进程完成后再使用Java继续操作



本质上,我正在制作一个小程序,它将安装一些软件,然后运行一些基本命令来准备该程序。然而,实际情况是程序开始安装,然后立即转到以下行(注册、更新等)。当然,在它完全安装之前,这是不可能发生的,所以我想找到一种在运行第二个进程之前等待第一个进程的方法。例如,

    Main.say("Installing...");
    Process p1 = Runtime.getRuntime().exec(dir + "setup.exe /SILENT");
    //Wait here, I need to finish installing first!
    Main.say("Registering...");
    Process p2 = Runtime.getRuntime().exec(installDir + "program.exe /register aaaa-bbbb-cccc");
    Main.say("Updating...");
    Process p4 = Runtime.getRuntime().exec(installDir + "program.exe /update -silent");

调用Process#waitFor()。其Javadoc表示:

如有必要,使当前线程等待,直到该Process对象表示的进程终止。

奖金:您可以获得子流程的退出值。因此,您可以检查它是否成功退出,代码为0,或者是否发生错误(非零退出代码)。

您可以使用Process.waitFor()方法

医生说

如有必要,使当前线程等待,直到进程由该进程对象表示的已终止。此方法返回如果子流程已经终止,则立即执行。如果子进程尚未终止,调用线程将被阻止直到子流程退出。

如果您运行的系统命令返回一个很长的响应字符串,stdin缓冲区就会填满,进程就会挂起。这发生在我使用sqlldr时。如果出现这种情况,那么只需在进程运行时从stdin读取即可。

    try {
        ProcessBuilder pb = new ProcessBuilder("myCommand");
        Process p = pb.start();
        BufferedReader stdInput = new BufferedReader(new 
                InputStreamReader(p.getInputStream()));
        BufferedReader stdError = new BufferedReader(new 
                InputStreamReader(p.getErrorStream()));
        StringBuffer response = new StringBuffer();
        StringBuffer errorStr = new StringBuffer();
        boolean alreadyWaited = false;
        while (p.isAlive()) {
            try {
                if(alreadyWaited) {
                    // read the output from the command because
                    //if we don't then the buffers fill up and
                    //the command stops and doesn't return
                    String temp;
                    while ((temp = stdInput.readLine()) != null) {
                        response.append(temp);
                    }

                    String errTemp;
                    while ((errTemp = stdError.readLine()) != null) {
                        errorStr.append(errTemp);
                    }                                                   
                }
                Thread.sleep(1000);
                alreadyWaited = true;
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            logger.debug("Response is " + response);
            logger.debug("Error is: " + errorStr);
        }
    } catch (IOException e) {
        logger.error("Error running system command", e);
    }

包含waitFor。在您的情况下,您的代码如下所示。

    Main.say("Installing...");
    Process p1 = Runtime.getRuntime().exec(dir + "setup.exe /SILENT");
    p1.waitFor()
    Main.say("Registering...");
    Process p2 = Runtime.getRuntime().exec(installDir + "program.exe /register aaaa-bbbb-cccc");
    Main.say("Updating...");
    Process p4 = Runtime.getRuntime().exec(installDir + "program.exe /update -silent");

最新更新