ThreadPoolExecutor的重要参数

1.corePoolSize:核心线程数

核心线程会一直存活,即使没有任务需要执行。

当线程数小于核心线程数时,即使有线程空闲,线程池也会优先创建新线程处理。

设置allowCoreThreadTimeout=true(默认false)时,核心线程会超时关闭。

2.queueCapacity:任务队列容量(阻塞队列)

当核心线程数达到最大时,新任务会放在队列中排队等待执行。

3.maxPoolSize:最大线程数

当线程数>=corePoolSize,且任务队列已满时。线程池会创建新线程来处理任务。

当线程数=maxPoolSize,且任务队列已满时,线程池会拒绝处理任务而抛出异常。

4.keepAliveTime:线程空闲时间

当线程空闲时间达到keepAliveTime时,线程会退出,直到线程数量=corePoolSize。

如果allowCoreThreadTimeout=true,则会直到线程数量=0。

5.allowCoreThreadTimeout:允许核心线程超时

6.rejectedExecutionHandler:任务拒绝处理器

ThreadPoolExecutor执行过程

1.当线程数小于核心线程数时,创建线程(即使有空闲线程,也会创建新的线程)。

2.当线程数大于等于核心线程数,且任务队列未满时,将任务放入任务队列。

3.当线程数大于等于核心线程数,且任务队列已满。(1)若线程数小于最大线程数,创建线程。(2)若线程数等于最大线程数,抛出异常,拒绝任务。

java线程池类型及选择

通过查看源码,java中存在以下线程池:

1.public static ExecutorService newFixedThreadPool()

2.public static ExecutorService newWorkStealingPool()

3.public static ExecutorService newSingleThreadExecutor()

4.public static ExecutorService newCachedThreadPool()

5.newScheduledThreadPool()

下面分别解释每一种线程池特点和使用场景:

1.public static ExecutorService newFixedThreadPool()

创建一个定长线程池,可控制线程最大并发数,超出的线程会在队列中等待。

2.public static ExecutorService newWorkStealingPool()

jdk1.8新引进的线程池,创建一个拥有多个任务队列(以便减少连接数)的线程池。由于能够合理的使用CPU进行对任务操作(并行操作),所以适合使用在很耗时的任务中。

3.public static ExecutorService newSingleThreadExecutor()

返回一个只有一个线程的线程池,这个线程池可以在线程死后(或发生异常时)重新启动一个线程来替代原来的线程继续执行下去!

4.public static ExecutorService newCachedThreadPool()

创建一个可缓存线程池,如果线程池长度超过处理需要,可灵活回收空闲线程,若无可回收,则新建线程。

5.newScheduledThreadPool()

创建一个线程池,支持定时及周期性任务执行,它可安排在给定延迟后运行命令或者定期地执行。

各种线程池应用场景

1.CachedThreadPool:适合使用在任务量大但耗时少的任务。

2.FixedThreadPool:适合使用在任务量比较固定但耗时长的任务。

3.ScheduledThreadPool:适合使用在执行定时任务和具体固定周期的重复任务。

4.SingleThreadPool:适合使用在多个任务顺序执行的场景。

5.newWorkStealingPool:适合使用在很耗时的任务中

Java线程池参数如何设置更合理

1.线程池的默认值

corePoolSize=1

queueCapacity=Integer.MAX_VALUE

maxPoolSize=Integer.MAX_VALUE

keepAliveTime=60s

allowCoreThreadTimeout=false

rejectedExcutionHandler=AbortPolicy()

这个需要根据具体任务和机器性能来综合考虑,通过不断的性能测试,分析出最佳线程数量。一般来讲:

1.CPU密集型:cpu利用率较高,设置线程数量和cpu核数一样即可。使cpu得到充分利用。

2.IO密集型:IO密集型,主要进行长时间的IO操作,cpu利用率不如cpu密集型高,一般设置线程数为CPU两倍。

其他问题:

两种情况会拒绝处理任务:(1)当线程数已经达到maxPoolSize,切队列已满,会拒绝新任务。(2)当线程池被调用shutdown()后,会等待线程池里的任务执行完毕,再shutdown。如果在调用shutdown()和线程池真正shutdown之间提交任务,会拒绝新任务。线程池会调用rejectedExecutionHandler来处理这个任务。如果没有设置默认是AbortPolicy,会抛出异常。

Logo

腾讯云面向开发者汇聚海量精品云计算使用和开发经验,营造开放的云计算技术生态圈。

更多推荐