@Test
public void thread(){
    //池化技术 ：1.复用率 2.有效控制 3.性能
    //原生线程池 7个参数
    /**
     * 使用原生线程池创建
     * 7个参数
     * 1.核心线程数
     * 2.最大线程数
     * 3.空闲时间
     * 4.空闲时间的时间单位
     * 5.阻塞队列 7种
     * 6.线程工厂
     * 7.拒绝策略 4种
     * 线程池工作原理：先核心线程-->再阻塞队列-->最大线程数-->拒绝策略*/
    ThreadPoolExecutor poolExecutor=new ThreadPoolExecutor(4,10,
            10, TimeUnit.SECONDS,new ArrayBlockingQueue<>(10),
            Executors.defaultThreadFactory() ,
            new ThreadPoolExecutor.AbortPolicy());
    //设置是否回收核心线程
    poolExecutor.allowCoreThreadTimeOut(true);
    //线程池的线程预热
    poolExecutor.prestartAllCoreThreads();
    //添加任务
    poolExecutor.execute(()->{
        System.err.println("遇见辉哥说：线程池在处理任务");
    });
}

• 如果发现线程池中有空闲线程，则直接执行该任务；

• 如果没有空闲线程，且当前运行的线程数少于corePoolSize，则创建新的线程执行该任务；

• 如果没有空闲线程，且当前的线程数等于corePoolSize，同时阻塞队列未满，则将任务入队列，而不添加新的线程；

• 如果没有空闲线程，且阻塞队列已满，同时池中的线程数小于maximumPoolSize ，则创建新的线程执行任务；

• 如果没有空闲线程，且阻塞队列已满，同时池中的线程数等于maximumPoolSize，则根据构造函数中的 handler 指定的策略来拒绝新的任务。

@Override
public R uploadExcel(MultipartFile file) throws IOException {
    //1.获取上传的内容 2.解析文件 3.线程池批量新增
    //1.验证上传文件是否非空
    if(!file.isEmpty()){
        //2.获取上传内容
        InputStream is=file.getInputStream();
        
        //3.解析Excel
        EasyExcel.read(is,Department.class,new PageReadListener<Department>((list)->{
            
            //使用线程池，保证每个线程处理的数据量不超过1000条
            //每个线程处理1000条数据，然后根据数据进行分片，每次计算每个任务完成的数据量的范围
            int i=0;
            int j=list.size()%1000==0?list.size()/1000:list.size()/1000+1;
            //循环添加任务到线程池中
            for(int m=1;m<=j;m++){
                ArrayList l=new ArrayList();
                l.addAll(list.subList((m-1)*1000,m*1000));
                
                ThreadPoolUtil.getInstance().poolExecutor.execute(()->{
                    //4.调用 dao 实现批量新增
                    dao.addBatch(l);
                });
            }
        })).sheet().doRead();
    }
    
    return R.ok();
}

//采用单例模式的IoDH封装线程池的工具类
public class ThreadPoolUtil {
    //线程池对象
    public ThreadPoolExecutor poolExecutor;
    //构造函数私有化
    private ThreadPoolUtil(){
        //完成线程池对象的实例化
        poolExecutor=new ThreadPoolExecutor(4,10,3, TimeUnit.SECONDS,
                new ArrayBlockingQueue<>(20), Executors.defaultThreadFactory(),
                new ThreadPoolExecutor.AbortPolicy());
    }
    //静态内部类 完成对象的实例化 
    private static class PoolInner{
        private final static ThreadPoolUtil pool=new ThreadPoolUtil();
    }
    //获取唯一实例
    public static ThreadPoolUtil getInstance(){
        return PoolInner.pool;
    }
}

• 线程池适合处理耗时的任务，可以充分使用目前服务器的硬件资源，加快处理的速度；

• 使用线程池时，不要死板，要结合自己的实际业务需求；

• 先写出基本的代码，然后再进行测试，一定要测试，至于说线程池的核心参数该如何设置，还是得根据你们实际的请求来决定。