ThreadPoolExcutor线程池使用

Posted 2021-09-27 可爱小海豚

一、ThreadPoolExcutor创建

private static final ThreadPoolExecutor THREADPOOL =  new ThreadPoolExecutor(int corePoolSize, int maximumPoolSize,long keepAliveTime, TimeUnit unit,BlockingQueue<Runnable> workQueue,RejectedExecutionHandler handler)

     corePoolSize：线程池维护线程的最少数量 （核心线程数）
     maximumPoolSize：线程池维护线程的最大数量 （最大线程数）
     keepAliveTime：线程池维护线程所允许的空闲时间 （最大线程数 - 核心线程数）
     unit：线程池维护线程所允许的空闲时间的单位（默认60s）
     workQueue：线程池所使用的缓冲队列 （默认无限队列）
     handler：线程池对拒绝任务的处理策略

二、ThreadPoolExcutor内部执行流程

通过 execute(Runnable)方法被添加到线程池，任务就是一个 Runnable类型的对象，任务的执行方法就是 Runnable类型对象的run()方法。

当一个任务通过execute(Runnable)方法欲添加到线程池时：

如果此时线程池中的数量小于corePoolSize，即使线程池中的线程都处于空闲状态，也要创建新的线程来处理被添加的任务。

    1、如果此时线程池中的数量等于 corePoolSize，但是缓冲队列 workQueue未满，那么任务被放入缓冲队列。
   2、如果此时线程池中的数量大于corePoolSize，缓冲队列workQueue满，并且线程池中的数量小于maximumPoolSize，建新的线程来处理被添加的任务。
    3、如果此时线程池中的数量大于corePoolSize，缓冲队列workQueue满，并且线程池中的数量等于maximumPoolSize，那么通过 handler所指定的策略来处理此任务。

    核心线程corePoolSize、任务队列workQueue、最大线程maximumPoolSize，如果三者都满了，使用handler处理被拒绝的任务。
三、ThreadPoolExcutor拒绝策略

1、ThreadPoolExecutor.AbortPolicy():抛出java.util.concurrent.RejectedExecutionException异常

    2、ThreadPoolExecutor.CallerRunsPolicy():重试添加当前的任务，他会自动重复调用execute()方法

3、ThreadPoolExecutor.DiscardOldestPolicy():抛弃旧的任务
4、ThreadPoolExecutor.DiscardPolicy():抛弃当前的任务

四、ThreadPoolExcutor注意事项

1、setQueueCapacity设置队列大小是一定要手动设置的，否则会默认无限队列，这也是为什么阿里规约不让使用Executors创建线程池的主要原因，因为Executors源码中默认无限队列。
2、setMaxPoolSize 最大线程数是 在队列满的情况下才会启用，否则一直不会启用的。
3、setCorePoolSize 核心线程数是一直在跑的,因此最大线程数一定要大于等于核心线程数才有意义。