RuntimeUtils.jsh

import java.io.*;
import java.util.concurrent.*;
import java.util.function.Consumer;

ExecutorService executorService = Executors.newSingleThreadExecutor();

System.out.println("Executing command: " + args[0]);
try {
    Process proc = Runtime.getRuntime().exec(new String[]{"/bin/sh", "-c", args[0]});
    StringBuilder sb = new StringBuilder();
    Runnable streamGobbler = new Runnable() {
        @Override
        public void run() {
            new BufferedReader(new InputStreamReader(proc.getInputStream())).lines()
                    .forEach(sb::append);
            new BufferedReader(new InputStreamReader(proc.getErrorStream())).lines()
                    .forEach(sb::append);
        }
    };        

    Future<?> future = executorService.submit(streamGobbler);

    if (!proc.waitFor(30, TimeUnit.SECONDS)) {
        throw new IOException("Execution timed out for command: " + args[0]);
    }

    future.get(10, TimeUnit.SECONDS);
    if (proc.exitValue() != 0) {
        throw new IOException(sb.toString());
    }
    System.out.println(sb.toString());
} catch (IOException e) {
    throw new UncheckedIOException(e);
} catch (InterruptedException | ExecutionException | TimeoutException e) {
    throw new RuntimeException(e);
}