public void testTooLongTask() throws Exception { final CountDownLatch latch = new CountDownLatch(5); Executer executer = new Executer(new Runnable() { public void run() { try { Thread.sleep(20); latch.countDown(); } catch (InterruptedException e) { e.printStackTrace(); } } }); executer.start(10); assert latch.await(1, TimeUnit.SECONDS); }