Java使用Runtime.getRuntime()去调用python时候，不能够实时输出python里面的print输出

Posted 2023-04-14

如，print '1' time.sleep(5) print '2'.。java用流去读的时候，必须等待5秒后，会同时打印出1、2，但是在DOS下直接调用python时，是可以会先打印1，等待5秒，再打印出2。而用这种方式调用bat脚本的时候，就不会出现这种问题

请不要不验证的就转载他人回答

参考技术A 这个就是管道的问题，在windows下经常会无语遇到这些问题。曾经为这个事情专门写了一个复杂的算法。

你换成linux开发环境再试验 ，就应该不存在这个问题了。 windows对于IO管理，包括标准IO支持的比较怪异。有时候它缓存了，有时候它不生效。追问

不对，我在linux下是一样的，不能够实时输出。windows在DOS下调用python是没有问题的，通过java去调用就有问题了。另外通过java调用bat脚本也是没有问题的

使用java.lang.Runtime.getRuntime无法在matlab中调用多个python脚本实例

我在Windows 10上运行Matlab2017。我调用一个python脚本，在云上运行一些语音识别任务，如下所示：

 userAuthCode=1;% authentication code for user account to be run on cloud
 cmd = ['C:\Python27\python.exe runASR.py userAuthCode];  
 system(cmd);

当调用上面的命令时，python脚本在ASR云引擎上运行输入音频文件，并且在运行时，我可以在Matlab控制台中看到来自Python的音频文件的语音识别分数。我想做以下事情：

（1）并行执行多个这样的命令。可以说，我有2个输入音频文件（每个都有不同的音频段），我想运行上面的命令2次，但并行，使用单独的进程。我能够创建一个应该能够执行此操作的代码段：

 for i=1: 2
     userAuthCode=i;
     cmd = ['C:\Python27\python.exe runASR.py userAuthCode];  
     runtime = java.lang.Runtime.getRuntime();        
     pid(i) = runtime.exec(cmd);
 end

 for i=1:2
    pid(i).waitFor();
    % get exit status
    rc(i) = pid(i).exitValue();       
 end

现在，当执行上面的代码时，我可以看到data1的ASRE分数，但不能看到数据2的ASRE分数。 变量rc中的退出状态为0,1，这证实了这一点。问题是我不知道错误的原因，因为Matlab中没有打印任何内容。如何从java / Matlab变量中捕获的Python中获取错误消息，以便我可以看看？

问题可能是并不支持多个并行呼叫（当然使用不同的用户帐户），但除非我能看到错误，否则我不会知道。

（2）当我独立运行单个命令时，如帖子开头所述，我能够在Matlab控制台中看到每个音频片段的Score消息，因为它们是从Python获得的。但是，使用java.lang.Runtime.getRuntime（）和相关代码进行多处理时，Matlab控制台中不会显示任何消息。有没有办法显示这些消息（我假设显示可能是异步的？）

谢谢 sedy

答案

一种方法是在Python中使用多处理。结果和任何错误消息都可以在列表中返回。

例：

假设您有三个音频文件，your_function将同时运行3次并返回错误消息。

import subprocess
from multiprocessing import Pool, cpu_count

def multi_processor(function_name):

    # Use a regex to make a list of full paths for audio files in /some/directory
    # You could also just pass in a list of audio files as a parameter to this function
    file_list = []
    file_list = str(subprocess.check_output("find ./some/directory -type f -iname \"*a_string_in_your_aud_file_name*\" ",shell=True)).split('\\n')
    file_list = sorted(file_list)

    # Test, comment out two lines above and put 3 strings in the list so your_function should run three times with 3 processors in parallel
    file_list.append("test1")
    file_list.append("test2")
    file_list.append("test3")

    # Use max number of system processors - 1
    pool = Pool(processes=cpu_count()-1)
    pool.daemon = True

    results = {}
    # for every audio file in the file list, start a new process
    for aud_file in file_list:
        results[aud_file] = pool.apply_async(your_function, args=("arg1", "arg2"))

    # Wait for all processes to finish before proceeding
    pool.close()
    pool.join()

    # Results and any errors are returned
    return {your_function: result.get() for your_function, result in results.items()}


def your_function(arg1, arg2):
    try:
        print("put your stuff in this function")
        your_results = ""
        return your_results
    except Exception as e:
        return str(e)


if __name__ == "__main__":
    multi_processor("your_function")