Gist.java

void shouldRemoveThreadsAfterCoreThreadTimeoutPeriod() throws Throwable {
        ThreadPoolExecutor tpe = prepareTestThreadPool(threadCount, timeoutMillis);

    long t0 = System.nanoTime();
    for (int i = 0; i < threadCount; i++)
            tpe.submit(new Runnable() { public void run() {}});
    
    int count = countExecutorThreads();
    if (millisElapsedSince(t0) < timeoutMillis)
            assertEquals(count, threadCount);
    
    
    while (countExecutorThreads() > 0 &&
            millisElapsedSince(t0) < 10 * 1000);
    assertEquals(countExecutorThreads(), 0);
    tpe.shutdown();
    
    
    assertTrue(tpe.allowsCoreThreadTimeOut());
    assertTrue(tpe.awaitTermination(10, TimeUnit.SECONDS));
}