多线程 – Groovy记录进程输出的方法

我想在我的Grails应用程序中启动一个长时间运行的命令行进程,当它到达时将每行输出记录到控制台,并异步执行其他操作,同时进程和日志记录活动继续进行. (在某些时候,我想要对每行输出做一些其他事情,比如记录到文件或查找某些值并触发其他操作.但是为了这个问题的目的,登录到控制台是好的.)

下面是我提出的执行此操作的代码.它工作,但启动记录器线程没有明确地终止它困扰我一点 – 它会正常终止吗？它会变成僵尸吗？我宁愿告诉Groovy将进程输出直接发送到System.out流 – 类似于command.execute(outputStream = System.out) – 但是没有找到一种非阻塞的方法来做到这一点.你能建议一个更好的方法吗？

def runcommand(command) {
    def process = command.execute()
    def out = process.getInputStream()
    def logger = Thread.start { out.eachLine { println it } }
    process.waitForOrKill(TIMEOUT_IN_MILLIS)
    return process // use to get exit code et cetera
}

解决方法

看看 Groovy docs for Process,我看到有一个方法consumeProcessOutput(OutputStream输出,OutputStream错误).我试着用以下方式重写你的方法,希望它是非阻塞的：

def runcommand(command) {
  def process = command.execute()
  process.consumeProcessOutput(System.out,System.err)
  println 'requested consume output' //hoping this will come out first
  process.waitForOrKill(TIMEOUT_IN_MILLIS)
  return process // use to get exit code et cetera
}

当我使用命令’dir’在Windows XP上运行它时,我得到以下输出：

requested consume output
file1    file2  ...

成功！

原文地址：https://www.jb51.cc/java/120786.html

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 [e-mail] 举报，一经查实，本站将立刻删除。

• 上一篇：java – 如何在类构造函数运行之前下一篇：java-ee – 如何为一个类实例化多个