ExecutorService pool = Executors.newCachedThreadPool();
pool.submit(dbClient);
pool.submit(dbClient);
pool.submit(dbClient);
pool.submit(dbClient);
<BUG>TimeUnit.SECONDS.sleep(2);
</BUG>
queryTheDb.set(false);
pool.shutdown();
}

ExecutorService pool = Executors.newCachedThreadPool();
pool.submit(dbClient);
pool.submit(dbClient);
pool.submit(dbClient);
pool.submit(dbClient);
TimeUnit.SECONDS.sleep(5);
queryTheDb.set(false);
pool.shutdown();
