等待java中用C++编写的多线程程序

Question

我用 C++ 编写了一个使用多线程的程序。使用 bash 脚本或类似的东西调用这个程序没问题，一切正常。现在我想用 Java 调用这个程序。这是我尝试过的 Java 代码示例：

Process v2j = new ProcessBuilder("./src/main/cpp/vcd_converter",
                 "-vcd", vcdfilePath, "-out", logfilePath).start();                     

InputStream is = v2j.getInputStream();
InputStream es = v2j.getErrorStream();

for(int i = 0; i < is.available(); i++) {
    System.out.println("Input: " + br.readLine());
}
for(int i = 0; i < es.available(); i++) {
    System.out.println("Error: " + ebr.readLine());
}
                                    
v2j.waitFor();

因此，如果我运行此代码，将发生以下情况：waitFor() 指令似乎不会真正等待“所有”线程，也许它只会等待一个。但是，java 程序执行时出错，因为它找不到由 C++ 程序生成的文件。所以waitFor() 不要等到我的 c++ 程序完成并生成文件。

输出也很奇怪。我只从std::cout 得到一个输出。这是一个例子：

std::cout << out_folder_path << "\n" << vcd_filename << "\n";
std::cout << std::flush;

这将只打印out_folder_path 输出。一个问题是：在std::cout 部分我什至不使用多线程。程序中的所有其他std::cout 也不打印。

所以我的问题是：我如何才能真正等待所有线程？我怎样才能得到我的程序的真正输出？

Answer 1

您的程序不会从 C++ 程序获得所有输出，因为它在输入流耗尽之前不会读取。如果 C++ 程序在您的程序到达 is.available() 时没有产生任何输出，它会跳转到 waitFor。

这是一种在输入流关闭之前进行读取的替代方法。它使用InputStreamReader 和BufferedReader 并调用BufferedReader 的readline() 直到输入流关闭。

_{免责声明。我之前没有写过任何java程序，所以我不确定我是否一切都正确。不过总体思路应该可行。}

var v2j = new ProcessBuilder("./src/main/cpp/vcd_converter", "-vcd", 
                             vcdfilePath, "-out", logfilePath).start();

InputStream is = v2j.getInputStream();
try(var reader = new BufferedReader(new InputStreamReader(is))) {
    String line;

    while ((line = reader.readLine()) != null) {
        System.out.println("Input: " + line);
    }
}

InputStream es = v2j.getErrorStream();
try(var reader = new BufferedReader(new InputStreamReader(es))) {
    String line;

    while ((line = reader.readLine()) != null) {
        System.out.println("Error: " + line);
    }
}

v2j.waitFor();