使用executorservice控制运行时进程

Question

我使用一个Runnable对象来运行processCommand并执行一些需要一定时间的处理（我们称之为insideprocess）。在insideprocess的末尾，它将向文本文件写入一些内容。其思想是，如果在指定的时间内insideprocess仍未完成，则必须将其杀死，因此我使用ExecutorService来处理它。但是如果insideprocess早于指定时间完成，它将中断ExecutorService以便主线程可以继续执行下一个任务。

但问题是，有时insideprocess根本没有创建文件，或者它创建了一个文件，但文件中没有写入任何内容。当insideprocess早于指定时间完成时，就会发生这种情况。我不知道我的实现出了什么问题。请注意，如果我手动执行流程（不使用ExecutorService），流程运行良好，并且它正确地编写了所有内容。

在这里，我发布了我的html" target="_blank">代码来完成这项工作：

public void process(){


    for (int i = 0; i < stoppingTime.length; i++) {
        for (int j = 2 * i; j < 2 * (i + 1); j++) {
            final int temp = j;
            ExecutorService executor = Executors.newSingleThreadExecutor();

            Runnable r = new Runnable() {

                @Override
                public void run() {
                    Process p = null;

                    int ex = 1;

                    try {
                        p = Runtime.getRuntime().exec(
                                processCommand.get(temp));

                        while (ex != 0) {
                            try {
                                //sleep every 30 second then check the exitValue
                                Thread.sleep(30000);
                            } catch (InterruptedException e) {

                            }
                            ex = p.exitValue();
                            p.destroy();                                
                        }                           
                    } catch (IOException e) {
                        e.printStackTrace();
                        System.out.println("IOException");
                    }
                }

            };

            Future future = executor.submit(r);

            try {
                System.out.println("Started..");
                future.get(stoppingTime[i], TimeUnit.SECONDS);                  
                System.out.println("Finished!");
            } catch (TimeoutException e) {
                System.out.println("Terminated!");
            } catch (InterruptedException e) {
                System.out.println("Future gets InterruptedException");
            } catch (ExecutionException e) {
                System.out.println("Future gets ExecutionException");
            }
            executor.shutdownNow();
            System.out.println("shutdown executor");
        }
        System.out.println();
    }

}

Answer 1

老问题，我想我还是要试试。

首先，您将在双循环中获得一个executorservice，它与定义的runnable位于同一块中。如果您希望获得本机执行“processCommand”的返回值，然后继续执行下一个任务，那么您需要在循环之前实例化ExecutorService来重用该ExecutorService。

其次，stoppingtime[i]是int，而future.get(...)需要long。