ShutdownAndAwaitTermination.java

void shutdownAndAwaitTermination(ExecutorService pool) {
    pool.shutdown(); // (1)
    try {
        if (!pool.awaitTermination(60, TimeUnit.SECONDS)) { // (2)
            pool.shutdownNow(); // (3)
            if (!pool.awaitTermination(60, TimeUnit.SECONDS)) // (4)
                System.err.println("Pool did not terminate"); // (5)
        }
    } catch (InterruptedException ex) { // (6)
        pool.shutdownNow(); // (7)
        Thread.currentThread().interrupt(); // (8)
    }
}