Java 进程执行 n 秒并打印输出

Question

我有一个 python 脚本，它下载一个文本文件，逐行读取它并将读取的行发送到 java。我需要将此操作限制为 5 秒，并接收 python 读取的任何内容。

为了测试一切是否正常，我尝试了这个：

import java.io.File;
import java.io.BufferedReader;
import java.io.FileReader;
import java.io.InputStreamReader;
import java.util.concurrent.TimeUnit;

class ProcessTest {
    public static void main(String args[]) {
        try {
            File file = new File("/home/local/seconds.py");
            BufferedReader reader = new BufferedReader(new FileReader(file));
            String testCase = "", temp = "";
            while ((temp = reader.readLine()) != null) {
                testCase = testCase.concat(temp + '\n');
            }
            reader.close();
            ProcessBuilder pb = new ProcessBuilder("python", "-c", testCase);
            Process p = pb.start();
            if (!p.waitFor(5, TimeUnit.SECONDS)) {
                reader = new BufferedReader(new InputStreamReader(p.getInputStream()));
                while ((temp = reader.readLine()) != null) {
                    System.out.println(temp);
                }
                p.destroy();
                System.out.println("not ended");
            } else {
                System.out.println("ended");
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

seconds.py 文件

from time import sleep
for i in range(1,11):
    print(i)
    sleep(1)

预期结果： 由于我已将进程 waitFor 的值指定为 5 秒，因此代码最多只能打印 5 秒。

得到的结果： 代码执行超过 5 秒，最多打印 10 秒。

如何设置进程的超时时间并打印缓冲区中的内容？

Answer 1

waitFor 不适合这种情况。

waitFor 不会改变进程产生的输出量。无论您等待多长时间，您的循环都会消耗该过程可以产生的每一行输出。

就此而言，在大多数系统上，如果进程的输出没有被定期消耗，则进程可能会挂起，因此waitFor 在与打印输出的进程一起使用时可能不会按预期运行。

正如其他人指出的那样，p.wait(); 在这里不正确。该方法与流程无关；是继承的Object.wait方法，用于多线程之间的协作。

最简单的方法是简单地检查经过的时间：

Process p = pb.start();
long startTime = System.currentTimeMillis();
reader = new BufferedReader(new InputStreamReader(p.getInputStream()));
while ((temp = reader.readLine()) != null) {
    long time = System.currentTimeMillis();
    if ((time - startTime) >= 5000) {
        p.destroy();
        System.out.println("not ended");
    }
    System.out.println(temp);
}
if (temp == null) {
    System.out.println("ended");
}
reader.close();