如何解决您如何在Kotlin Web服务协程请求中实现响应的Shell脚本?
我使用spring boot 2和Kotlin创建了一个Web服务,以通过流程构建器访问同一服务器的相同UNIX脚本和其他程序。响应消息应包含我使用的shell脚本的标准输出。但是我对科特林的协程有疑问。当我使用 process.waitFor()时,这是一个阻止函数。您如何使用专用线程(池)来跟踪外部进程并在这段时间内暂停协程? 在下面的代码片段中,您将看到如何获取shell脚本的返回代码以及该脚本的stdout信息:
val process = ProcessBuilder(cmd)
.redirectErrorStream(true)
.start()
val exitCode = process.waitFor()
return CmdResult(
exitCode,process.inputStream
)
我在以下试验中失败了,因为我没有获得标准输出信息,并且不知道如何将结果用作范围外的返回类型:
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
)
}
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。