java - Groovy/Java 进程管理拦截/监听输出

Question

Groovy 有一个很好的流程执行引擎，我想使用它。
有一个方法 consumeProcessOutput 可以完成所有必要的工作。但我想要的是在每次 consumeProcessOutput 调用 append 或 out 实例时注入(inject)我的附加功能.

public class ProcessExecutor {
   static public void execute(IOutput output, String processName) {
      def process = processName.execute()

      def out = new StringBuffer()
      process.consumeProcessOutput(out, out)

      process.waitFor()
   }
}

我知道

use (MyStringBufferIntercept) {
   process.consumeProcessOutput(out, out)
}

但它们似乎只适用于当前线程，consumeProcessOutput 会创建额外的线程。

那么有没有办法监听行添加并调用output.addLine(line)和output.addErrorLine(line)？

到目前为止，我只有一种解决方案，当错误输出与正常输出相当快时效果不佳:顺序更改。

  def process = processName.execute()

  def inThread = Thread.start {
     process.in.eachLine{ line -> output.addLine(line)}
  }

  def errThread = Thread.start {
     process.err.eachLine{ line -> output.addErrorLine(line)}
  }

  inThread.join()
  errThread.join()

  process.waitFor()

我同意 Java 解决方案。但我倾向于认为 groovy 的必须更优雅。

Answer 1

我不喜欢 Groovy 使用的从 process.in 和 process.err 读取并写入 process.out 的约定。 Javadocs 应该更清楚。看起来 err 和 out 是同类中的两个，in 是奇怪的 out。

由于您将进程的 stdout 和 stderr 多路复用到单个输出字符串中，所以个别行可能会出现乱码是对的。我不相信您可以将 synchronized 关键字与闭包一起使用，因此也许可以执行与下面的代码类似的操作，但可以使用锁定机制或者将大纲闭包包装在同步方法中。

class P {
 static public void execute( String processName) {
  def process = processName.execute()
  def output = new StringBuffer()

  def outline = { line -> output += line + '\n' }

 def inThread = Thread.start {
         process.in.eachLine{ outline it }
   }

 def errThread = Thread.start {
          process.err.eachLine{ outline it }
   }

       inThread.join()
       errThread.join()
       process.waitFor()
       println output
    }
 }

 def p = new P();
 p.execute("ls -l");