Java并发编程：线程池 - 实例

             1
            public
            class
             test {

             2
            public
            static
            void
             main(String[] args) {

             3         test t = new test();
 4         ThreadPoolExecutor executor = new ThreadPoolExecutor(5, 10, 200,
 5                 TimeUnit.MILLISECONDS, new LinkedBlockingDeque<Runnable>(5));
 6 7for (int i = 1; i < 16; i++) {
 8            t.testRun(executor, i);
 9             System.out.println("-- 线程池中的线程数 ：" + executor.getPoolSize() +
10                     " -- 对列中的线程数 ：" + executor.getQueue().size() +
11                     " -- 已执行完的线程数 ：" + executor.getCompletedTaskCount());
12        }
13        executor.shutdown();
14while (true) {
15if (executor.isTerminated()) {
16                 System.out.println("* ------ * 所有线程已结束");
17break;
18            }
19try {
20                 Thread.sleep(100);
21             } catch (InterruptedException e) {
22                e.printStackTrace();
23            }
24        }
2526    }
2728publicvoid testRun(ThreadPoolExecutor executor, finalint a) {
2930         executor.execute(new Thread(new Runnable() {
31            @Override
32publicvoid run() {
33                 System.out.println("线程 开始 ，线程 ：" + a);
34try {
35                     Thread.sleep(a * 1000);
36                 } catch (InterruptedException e) {
37                    e.printStackTrace();
38                }
39                 System.out.println("线程 结束，线程 ： " + a);
40            }
41         }, "name"));
4243    }
44 }