通用线程池2

 1 public enum CommonThreadPoolEnum {
 2 
 3     TAKE_PHONE_NUMBER_THREAD_POOL;
 4 
 5     private ThreadPoolExecutor executor;
 6 
 7     CommonThreadPoolEnum() {
 8         int corePoolSize = 6;
 9         int maximumPoolSize = 6;
10         int workQueue = 500;
11         executor = new ThreadPoolExecutor(corePoolSize, maximumPoolSize, 30000 L, TimeUnit.MILLISECONDS, 
12         new LinkedBlockingQueue<>(workQueue), 
13         new ThreadPoolExecutor.DiscardPolicy());
14         executor.allowCoreThreadTimeOut(true);//核心线程允许在空闲keepAlive时间后关闭。即这里设置为true后，线程池中的线程数可能会为0.
15     }
16 
17     /**
18      * 添加带返回值的任务
19      */
20     public <M> Future <M> add(Callable <M> task) {
21         return executor.submit(task);
22     }
23 
24     /**
25      * 添加不带返回值的任务
26      */
27     public void add(Runnable task) {
28         executor.execute(task);
29     }
30 }