时间戳

首页 > 解决方案 > ProcessBuilder 挂起

java - ProcessBuilder 挂起

问题描述

我使用以下代码运行命令：

open class AppRunner {

    fun run(
        app: String,
        args: Array<String>,
        timeoutAmount: Long = 6000,
        timeoutUnit: TimeUnit = TimeUnit.SECONDS
    ): AppResult {

        val command = mutableListOf(app)
            .apply {
                addAll(args)
            }

        val commandString = command.joinToString(" ") { "\"$it\"" }
        Kimber.d("Executing command: $commandString")

        val processResult = ProcessBuilder(command)
            .redirectOutput(ProcessBuilder.Redirect.PIPE)
            .redirectError(ProcessBuilder.Redirect.PIPE)
            .start()
            .apply {
                waitFor(timeoutAmount, timeoutUnit)
            }

        val exitCode = processResult.exitValue()
        val stdOut = processResult.inputStream.bufferedReader().readText()
        val stdErr = processResult.errorStream.bufferedReader().readText()

        return AppResult(exitCode, stdOut, stdErr)
    }

    data class AppResult(
        val exitCode: Int,
        val stdOut: String,
        val stdErr: String
    ) {

        fun isSuccessful(): Boolean = exitCode == 0

        fun getStdOutLines(): List<String> = stdOut.split("\n")
        fun getStdErrLines(): List<String> = stdOut.split("\n")

    }

}

像这样：

val args = arrayOf(
                audioFile.absolutePath,
                "-r",
                getRecognizer(language),
                "-f",
                "json",
                "-q"
        )

        val result = appRunner.run(rhubarbBinary.absolutePath, args)

对于某些类似的程序，ffmpeg它可以工作，但上面的示例没有。

«Raw» 命令是"/Users/user/<path>/rhubarb" "/var/folders/g6/bmyctvjn7fl3m8kdr0cs1hk80000gn/T/lipsync_audio_14979831388784829375.wav" "-r" "phonetic" "-f" "json" "-q"，如果我手动运行它，它工作正常。

但是，如果我使用上面的代码运行它，它就不会启动并冻结。

我确定它没有启动，因为此命令需要大约 30 秒才能完成，并且在运行时会消耗 100% 的 CPU，而使用此代码运行它时，它根本不会加载 CPU。

我在 JVM 8、macOS 10.15.4 上使用 Kotlin 1.3.71。

怎么了？

标签： javakotlinprocessbuilder

解决方案

您在读取管道输出之前等待程序结束，但管道只有有限的缓冲区，因此当缓冲区已满时，程序将等待您使用缓冲的输出，但您正在等待程序结束。僵局！

在调用之前总是消耗输出waitFor()。

更新

建议您更改代码如下：

val process = ProcessBuilder(command)
    .redirectErrorStream(true)
    .start()
val stdOut = processResult.inputStream.bufferedReader().readText()
if (process.waitFor(timeoutAmount, timeoutUnit)) {
    val exitCode = processResult.exitValue()
    return AppResult(exitCode, stdOut, "")
}
// timeout: decide what to do here, since command hasn't terminated yet

无需指定Redirect.PIPE，因为这是默认设置。如果您没有像此处所示加入 stderr 和 stdout，则需要创建线程以单独使用它们，因为它们都有缓冲区已满的问题，因此您不能先读取其中一个。

推荐阅读