Gist.java

private ThreadPoolExecutor threadPoolExecutor;

@BeforeMethod
void setUp() {
    threadPoolExecutor = prepareThreadPoolExecutor();
}

@AfterMethod
void tearDown() throws InterruptedException {
    threadPoolExecutor.shutdown();
    while (!threadPoolExecutor.isTerminated()) {
        Thread.sleep(20);
    }

    /*
     * Clean up our threadpool
     */
    assertTrue(threadPoolExecutor.awaitTermination(10, TimeUnit.SECONDS));
    threadPoolExecutor = null;
}