public void stop(boolean now) throws InterruptedException {
        if (now) {
            executorService.shutdownNow();
        } else {
            executorService.shutdown();
        }

        waitForTerminated();
    }
Stop and wait for shutdown.

@param now don't wait for pending jobs to start
stroom-util/src/main/java/stroom/util/concurrent/SimpleExecutor.java