import org.zeroturnaround.exec.InvalidExitValueException; //导入依赖的package包/类
/**
 * Executes this command.
 * @param timeout The allowed timeout
 * @param unit A time unit
 * @return This command
 * @throws TimeoutException See {@link ProcessExecutor#execute()}
 * @throws InvalidExitValueException See {@link ProcessExecutor#execute()}
 * @throws IOException See {@link ProcessExecutor#execute()}
 * @throws InterruptedException See {@link ProcessExecutor#execute()}
 */
public Command execute(long timeout, TimeUnit unit)
    throws TimeoutException, InvalidExitValueException, IOException,
        InterruptedException {
    final ByteArrayOutputStream outputStream = new ByteArrayOutputStream();
    final ByteArrayOutputStream errorStream = new ByteArrayOutputStream();
    final int exitCode = new ProcessExecutor()
        .environment(System.getenv())
        .directory(this.directory)
        .command(this.parts)
        .timeout(timeout, unit)
        .redirectOutput(outputStream)
        .redirectError(errorStream)
        .readOutput(true)
        .stopper((process) -> {
            process.destroyForcibly();
        })
        .execute()
        .getExitValue();
    this.result = new Result(
        exitCode,
        outputStream,
        errorStream
    );
    return this;
}
 

import org.zeroturnaround.exec.InvalidExitValueException; //导入依赖的package包/类
/**
 * Sends the destroy signal to this process.
 *
 * @param forceful <code>true</code> if this process should be destroyed forcefully.
 * @return <code>true</code> if this process got the signal, <code>false</code> if the process was not found (any more).
 *
 * @throws IOException on IO error.
 * @throws InterruptedException if interrupted.
 */
public boolean taskkill(boolean forceful) throws IOException, InterruptedException {
  try {
    new ProcessExecutor()
    .commandSplit(String.format("taskkill%s%s /PID %d", includeChildren ? " /T" : "", forceful ? " /F" : "", pid))
    .redirectOutput(Slf4jStream.ofCaller().asDebug()).exitValueNormal().executeNoTimeout();
    return true;
  }
  catch (InvalidExitValueException e) {
    if (e.getExitValue() == EXIT_CODE_COULD_NOT_BE_TERMINATED) {
      // Process could be either alive or not, if it's not alive we don't want to throw an exception
      if (isAlive()) {
        throw e; // process is still alive
      }
      return false; // process is stopped but but not because of us
    }
    if (e.getExitValue() == EXIT_CODE_NO_SUCH_PROCESS) {
      return false;
    }
    throw e;
  }
}
 

import org.zeroturnaround.exec.InvalidExitValueException; //导入依赖的package包/类
public boolean isAlive() throws IOException, InterruptedException {
  try {
    new ProcessExecutor()
    .commandSplit(String.format("kill -0 %d", pid)).readOutput(true)
    .redirectOutput(Slf4jStream.ofCaller().asTrace())
    .setMessageLogger(MessageLoggers.TRACE)
    .exitValueNormal()
    .executeNoTimeout();
    return true;
  }
  catch (InvalidExitValueException e) {
    if (isNoSuchProcess(e)) {
      return false;
    }
    throw e;
  }
}
 

import org.zeroturnaround.exec.InvalidExitValueException; //导入依赖的package包/类
/**
 * Run a shell command synchronously.
 *
 * @param command command to run and arguments
 * @return the stdout output of the command
 */
public static String runShellCommand(String... command) {

    String joinedCommand = String.join(" ", command);
    LOGGER.debug("Executing shell command: `{}`", joinedCommand);

    try {
        ProcessResult result;
        result = new ProcessExecutor()
                .command(command)
                .readOutput(true)
                .exitValueNormal()
                .execute();

        return result.outputUTF8().trim();
    } catch (IOException | InterruptedException | TimeoutException | InvalidExitValueException e) {
        throw new ShellCommandException("Exception when executing " + joinedCommand, e);
    }
}
 

import org.zeroturnaround.exec.InvalidExitValueException; //导入依赖的package包/类
/**
 * Sends a signal to this process.
 *
 * @param signal name of the signal.
 * @return <code>true</code> if this process received the signal, <code>false</code> if this process was not found (any more).
 *
 * @throws IOException on IO error.
 * @throws InterruptedException if interrupted.
 */
public boolean kill(String signal) throws IOException, InterruptedException {
  try {
    new ProcessExecutor()
    .commandSplit(String.format("kill -%s %d", signal, pid))
    .redirectOutput(Slf4jStream.ofCaller().asDebug()).exitValueNormal().executeNoTimeout();
    return true;
  }
  catch (InvalidExitValueException e) {
    if (isNoSuchProcess(e)) {
      return false;
    }
    throw e;
  }
}
 

import org.zeroturnaround.exec.InvalidExitValueException; //导入依赖的package包/类
@Override
protected boolean isNoSuchProcess(InvalidExitValueException e) {
  return e.getExitValue() == EXIT_CODE_NO_SUCH_PROCESS;
}
 

import org.zeroturnaround.exec.InvalidExitValueException; //导入依赖的package包/类
@Test(expected=InvalidExitValueException.class)
public void testJavaVersionExitValueCheck() throws Exception {
  new ProcessExecutor().command("java", "-version").exitValues(3).execute();
}
 

import org.zeroturnaround.exec.InvalidExitValueException; //导入依赖的package包/类
@Test(expected=InvalidExitValueException.class)
public void testJavaVersionExitValueCheckTimeout() throws Exception {
  new ProcessExecutor().command("java", "-version").exitValues(3).timeout(60, TimeUnit.SECONDS).execute();
}
 

import org.zeroturnaround.exec.InvalidExitValueException; //导入依赖的package包/类
@Test(expected=InvalidExitValueException.class)
public void testCustomExitValueInvalid() throws Exception {
  new ProcessExecutor(exitLikeABoss(17)).exitValues(15).execute();
}
 

import org.zeroturnaround.exec.InvalidExitValueException; //导入依赖的package包/类
/**
 * @param e process exited with an error code.
 * @return <code>true</code> if this exception indicates that the process was not found (any more).
 */
protected boolean isNoSuchProcess(InvalidExitValueException e) {
  return e.getExitValue() == EXIT_CODE_NO_SUCH_PROCESS;
}