我用spring-boot 2和Kotlin创建了一个web服务,通过流程生成器访问特定服务器的相同unix脚本和其他程序。响应消息应包含我使用的shell脚本的stdout。但我对科特林的郊游有意见。当我使用process.waitFor时,这是一个阻塞函数。如何使用专用线程(-池(来跟踪外部进程并在此期间挂起协同程序?在下面的代码片段中,您可以看到我是如何获得shell脚本的返回代码及其stdout信息的:
val process = ProcessBuilder(cmd)
.redirectErrorStream(true)
.start()
val exitCode = process.waitFor()
return CmdResult(
exitCode,
process.inputStream
)
我在下面的试验中失败了,因为我没有得到stdout信息,也不知道如何将结果从范围之外用作返回类型:
val dispatcher = newFixedThreadPoolContext(4, "myPool")
launch(dispatcher) {
val process = ProcessBuilder(listOf(cmdScript))
.redirectErrorStream(true)
.start()
val exitCode = process.waitFor()
CmdResult(
exitCode,
process.inputStream
)
}.join()
您可以使用顶级函数withContext
从协程返回:
val dispatcher = newFixedThreadPoolContext(4, "myPool")
val result = withContext(dispatcher) {
val process = ProcessBuilder(listOf(cmdScript))
.redirectErrorStream(true)
.start()
val exitCode = process.waitFor()
CmdResult(
exitCode,
process.inputStream
)
}