4

让我解释一下我的软件。我的软件所做的只是创建 10 个线程并为每个线程分配多个任务。然后每个线程创建一个运行时进程，该进程将启动一个 cmd 批处理文件，该文件又将启动一个程序，该程序将远程登录到一个设备（我有大约 200 个）以轮询其配置。这是我的流程创建的代码：

Process p1 = java.lang.Runtime.getRuntime().exec("cmd /c  start /b /wait " + batchFile); 
int returnVal = p1.waitFor();

batchFile是批处理文件的完整路径。不要误会我的意思，该软件在 100% 的执行情况下都可以正常工作，并且它只在 95% 左右挂起一次，所以我正在努力寻找解决方案。为什么它挂起现在不是我的问题，而是以后如何处理挂断..！

现在的问题是我需要等待进程完成，因为我的 telnet 客户端将写入一个文件，我稍后将在线程中读取该文件；因此使用.waitFor(). 我的问题是如何让线程了解外部程序挂起？换句话说，我可以给外部程序一些时间限制来完成吗？如果没有，线程会终止进程吗？

我还阅读了有关读取错误和输出流的信息；但是，我认为它不适用于这里，或者是吗？

4

1 回答 1

3

我还阅读了有关读取错误和输出流的信息；但是，我认为它不适用于这里，或者是吗？

几乎可以肯定是的，它是适用的。尝试使用ProcessBuilder代替Runtime.exec并在调用之前读取所有输出waitFor。例如（省略异常处理，特别是可能在进程实际退出之前waitFor抛出）InterruptedException

    ProcessBuilder pb = new ProcessBuilder(
        "cmd", "/c", "start", "/b", "/wait", batchFile);
    pb.redirectErrorStream(true);
    Process p = pb.start();
    IOUtils.closeQuietly(p.getOutputStream());
    IOUtils.copy(p.getInputStream(), System.out);
    // or alternatively throw away the output using
    // IOUtils.copy(p.getInputStream(), NullOutputStream.NULL_OUTPUT_STREAM);
    IOUtils.closeQuietly(p.getInputStream());
    int returnVal = p.waitFor();

（IOUtils 和 NullOutputStream 来自Apache commons-io）。

要回答标题中的实际问题，如果您的进程即使在正确读取其输出后仍然挂起，您可能需要使用p.destroy()强制终止进程。您可以定义一个计时器任务，例如

    public class TimeoutProcessKiller extends TimerTask {
      private Process p;
      public TimeoutProcessKiller(Process p) {
        this.p = p;
      }

      public void run() {
        p.destroy();
      }
    }

然后做

    // single shared timer instance
    Timer t = new Timer();

    // for each device
    Process p = pb.start();
    TimerTask killer = new TimeoutProcessKiller(p);
    t.schedule(killer, 30000);
    // ... read output stream as before ...
    int returnVal = p.waitFor();
    killer.cancel();

如果进程运行超过 30 秒，这将导致进程被杀死（调整schedule调用以更改超时）。

于 2013-01-23T15:56:32.947 回答