Gist.java

void test(String[] args) 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)
            equal(count, threadCount);
    
    
    while (countExecutorThreads() > 0 &&
            millisElapsedSince(t0) < 10 * 1000);
    equal(countExecutorThreads(), 0);
    tpe.shutdown();
    
    
    check(tpe.allowsCoreThreadTimeOut());
    check(tpe.awaitTermination(10, TimeUnit.SECONDS));
    
    System.out.printf("%nPassed = %d, failed = %d%n%n", passed, failed);
    if (failed > 0) throw new Exception("Some tests failed");
}