我正在尝试使以下代码正常工作，以便我可以在其他地方使用它。
实际上，它（应该）启动另一个进程，在其中运行 python，并为 python 提供一些命令。但是，在实践中，除非我关闭该进程的流，否则永远不会发送 python 命令。我认为 flush() 应该强制这种情况发生，但它似乎没有工作。谁能提供任何关于为什么 flush() 可能不起作用以及我可以做些什么来避免这种情况的见解？谢谢。
请注意，如果我调用 close()，则会发送命令。但是，我希望能够在这个命令之后发送更多命令，所以在这里使用 close() 似乎是不可接受的。（我最终会关闭（）一切）
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.util.Scanner;
public class Foo {
public static void main(String[] args) throws IOException {
Process cmd = Runtime.getRuntime().exec("python");
InputStream inStream = cmd.getInputStream();
Thread stdout = new Thread(new stdOutReader(inStream));
stdout.start();
InputStream errStream = cmd.getErrorStream();
Thread stderr = new Thread(new stdOutReader(errStream));
stderr.start();
OutputStream outStream = cmd.getOutputStream();
OutputStreamWriter os = new OutputStreamWriter(outStream);
PrintWriter pWriter = new PrintWriter(outStream, true);
pWriter.println("print \"Testing..\"");
pWriter.flush();
int x = 0;
while (x < 100){
//Do stuff here (will not be an infinite loop in actual code)
}
pWriter.close();
}
private static class stdOutReader implements Runnable{
InputStream inStream;
public stdOutReader(InputStream inStream){
this.inStream = inStream;
}
public void run() {
InputStreamReader reader = new InputStreamReader(this.inStream);
Scanner scan = new Scanner(reader);
while (scan.hasNext()) {
System.out.println(scan.next());
System.out.flush();
}
}
}
}