创建一个线程池需要哪些参数,参数的含义是什么呢?
来张图
![](https://img.haomeiwen.com/i23159042/3559428e0580e14a.png)
线程池的构造方法
一个一个的来说明
corePoolSize为当前线程池的核心线程数,maximumPoolSize为当前线程池可运行的最大线程数,keepAliveTime为当前线程池中,空闲的线程存活的时间,unit为时间单位,如果线程空闲的时间超过keepAliveTime则销毁(除开核心线程数corePoolSize),BlockingQueue存放任务的阻塞队列,ThreadFactory创建线程的工厂,可以通过自定义线程工厂给线程设置一个名称,RejectedExecutionHandler拒绝策略。是一个接口,SDK默认提供了4种实现方式,分别为AbortPolicy(该实现会抛出异常),CallerRunsPolicy(谁提交的任务还给谁),DiscardOldestPolicy(丢弃最老的任务,及当前阻塞队列中最靠前的任务),DiscardPolicy(直接丢弃新提交的任务).
好了,大概的意思就是这么个意思,那么具体有什么用呢?
当提交任务时,线程池中的任务数量小于corePoolSize,则启动线程执行任务,继续提交新任务,此时任务数量大于了corePoolSize,则会将任务先暂时存放入阻塞队列中,后续通过从阻塞队列中取任务来执行,如果还是继续提交任务,阻塞队列中的任务也满了,则会继续启动新的线程来执行任务,且线程池中的线程数在最大线程数maximumPoolSize范围之内,继续提交任务,最大线程数也满了,则到拒绝策略发挥作用了,前文已描述拒绝策略基本的4种方式,默认的拒绝策略为抛出异常。
假如corePoolSize =3 maximumPoolSize =6 BlockingQueue长度=1,此时有runnable1,runnable2,runnable3,runnable4,runnable5,runnable6,runnable7....,按顺序往线程池种提交, 此时的执行顺序为runnable1,runnable2,runnable3,runnable5,runnable6,runnable7,runnable4,可以看到runnable4先提交,却最后执行,因为runnable4存放在了阻塞队列中,阻塞队列长度=1,已满,又会在最大线程数范围内启动新的线程来执行
提交任务的方式 execute(Runnable command)和 submit(Callable task) ,submit会提供返回值
关闭线程池的方式 shutdown(), shutdownNow() :通过遍历线程池中的线程,逐个调用interrupt方法来发送中断信号,中断线程,所以并不是一定能成功中断,取决于线程有没有处理中断信号。两种方式有着一些区别。shutDown方法是尝试中断当前空闲的线程,shutDownNow是尝试中断所有线程,并返回等待执行任务的列表。只要调用了2种方法的任意一个,isShutDown方法就会返回true,当所有线程都关闭之后,才表示线程池关闭成功,这时的isTerminaed方法会返回true。通常调用shutdown方法来关闭线程池,如果任务不一定要执行完,则可以调用shutdownNow方法。
参数的含义大致如此,那么如何合理的配置最大线程数呢
取决于业务逻辑,大致分为2中情况
IO密集型,CPU密集型
CPU密集型,则最大线程数=CPU的核心数,sdk提供了方法,cpu核心数 = Runtime.getRuntime().availableProcessors(),最大也只能cpu核心数+1,以防止页缺失(当线程所需的数据在虚拟内存中,需要将数据读取到内存中,因为比较慢,该线程就会等待读取完成之后才会被唤醒)的情况。
IO密集型,则最大线程数 = CPU核心数*2,同样,最大也+1.
网友评论