1 package com.learn.threadTest;
 2 
 3 
 4 import java.util.concurrent.ArrayBlockingQueue;
 5 import java.util.concurrent.ExecutorService;
 6 import java.util.concurrent.TimeUnit;
 7 import java.util.concurrent.ThreadPoolExecutor;
 8 
 9 public class DefineThreadPoolFactory {
10     
11 
12     private final static int corePoolSize = 5;//活跃线程数
13     private final static int maximumPoolSize = 20;//最大线程数
14     private final static long keepAliveTime = 0;//临时线程活跃时长
15     
16     public static ExecutorService threadPoolFactory () {
17         ExecutorService executorService = new ThreadPoolExecutor(corePoolSize,maximumPoolSize,keepAliveTime,TimeUnit.SECONDS,new ArrayBlockingQueue<>(128));
18         return executorService;
19     }
20     public static void main(String[] arg0) {
21         threadPoolFactory().submit(new Runnable() {
22             @Override
23             public void run() {
24                 Thread.currentThread().setName("虾来了");
25                 System.out.println("获取到线程资源,线程名{"+Thread.currentThread().getName()+"}");
26                 System.out.println("获取到线程资源,线程名{"+Thread.currentThread().getId()+"}");
27             }
28         });
29     }
30 }