    @Test
    public void test006ExecutorService线程池占满() throws Exception {

        ThreadPoolExecutor executor = RetryUtil.createThreadPoolExecutor();
        expectedEx.expect(RejectedExecutionException.class);
        for (int i = 0; i < 10; i++) {
            executor.submit(new Callable<Object>() {
                @Override
                public Object call() throws Exception {
                    TimeUnit.SECONDS.sleep(10);
                    return null;
                }
            });
            System.out.println("Submit: " + i + ", running tasks: " + executor.getActiveCount());
        }

    }