package com.lc.concurrent;
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;public class MyThreadPoolExecutor {//最大可用的CPU核数public static final int PROCESSORS=Runtime.getRuntime().availableProcessors();//线程最大的空闲存活时间，单位为秒public static final int KEEPALIVETIME=60;//任务缓存队列长度public static final int BLOCKINGQUEUE_LENGTH=500;public ThreadPoolExecutor createThreadPool(){return new ThreadPoolExecutor(PROCESSORS * 2,PROCESSORS * 4,KEEPALIVETIME,TimeUnit.SECONDS,new ArrayBlockingQueue<Runnable>(BLOCKINGQUEUE_LENGTH));}
} 

package com.lc.concurrent;import java.util.Arrays;
import java.util.Random;
import java.util.concurrent.ThreadPoolExecutor;public class CreateThreads {public synchronized static void main(String[] args) {System.out.println(MyThreadPoolExecutor.PROCESSORS);new CreateThreads().test();}public synchronized void test(){ThreadPoolExecutor threadPoolExecutor=new MyThreadPoolExecutor().createThreadPool();for (int i = 0; i <= 100; i++) {MyTask myTask = new MyTask(i);threadPoolExecutor.execute(myTask);}threadPoolExecutor.shutdown();}}class MyTask implements Runnable{private int i;public MyTask(int i){this.i=i;}@Overridepublic void run() {System.out.println("任务"+i+"开始执行"+System.currentTimeMillis());for (int i=0;i<32766;i++){Random random=new Random();int randNum=random.nextInt();int[] a={1,2,3,4,5,6,9,18,290,238,991,100,19,1932,randNum};Arrays.sort(a);Arrays.hashCode(a);Arrays.stream(a);}System.out.println("任务"+i+"结束执行"+System.currentTimeMillis());}
}

   核心池线程数量     执行耗时（毫秒,多次测试结果以/间隔）4                   474/479/4718                   430/436/42112                  432/425/43816                  437/431/44920                  471/481/469