ThreadPoolExecutor 配置

这是ThreadPoolExecutor类前面的一段注释,讲了一些自定义线程池的策略,同时也包含了一些线程池的原理。

1.核心线程数与最大线程数

  • 线程池会根据corePoolSizemaximumPoolSize自动调整线程数

  • 提交任务时,如果当前线程数小于核心线程数则新建线程。

  • 大于core,小于max则只有当任务队列为满的时候会创建线程。

  • core和max相等的时候就创建了一个线程数目固定的线程池(fixed-size)

  • max设置为Integer.MAX_VALUE则说明是一个无界的线程池。

  • 可以使用setCorePoolSizesetMaximumPoolSize动态调整线程池

2.按需创建线程池

默认情况下核心线程是在任务提交时才创建的。可以使用prestartCoreThreadprestartAllCoreThread来提前创建线程池。
(如果你配置了一个非空任务队列的话)

3.创建新线程

  • 可以实现ThreadFactory接口(实现类要线程安全)来创建线程,默认使用Executors.defaultThreadFactory,默认实现创建的线程属于同一个ThreadGroup,而且有相同的优先级,线程为非守护线程。

  • 你可以自定义线程池来改变线程名字,线程组,优先级,是否为守护线程等等。

4.Keep-alive times

  • 如果当期线程池的数目大于core,空闲的线程或者超过keepAliveTime时间的线程会被终止。(getKeepAliveTime),这样资源如果不能充分利用可以回收一部分,降低消耗。

  • 如果线程池稍后负载变大则会重新创建线程。该参数同样可以动态调整setKeepAliveTime,如果设置为Long.MAX_VAlUE则不会终止空闲线程,

  • 这种自动调整的策略只针对线程数目大于core的那部分线程。也可以使用
    allowCoreThreadTime(boolean)来将该动态调整的策略应用于core线程。(前提是keepAliveTime非零)

5.任务队列

  • 可以使用任意的BlockingQueue来保存和提交任务。

  • 当前线程数少于corePoolSize,线程池一般会选择创建线程而不是将任务放在任务队列中。

  • 当前线程数大于corePoolSize,线程池一般会选择将任务放在任务队列中。

  • 如果一个任务不能入队(任务队列满)则创建线程。如果线程数目超过了maximumPoolSize,则任务会被拒绝。

6.任务等待(排队)策略

6.1 直接提交任务给工作线程

  • SynchronousQueue会直接将任务提交给工作线程。不会在队列内部保留任务(队列容量为0)。

  • 如果没有线程能马上运行任务则该任务不能提交到任务队列中(相当于任务队列为满),这时候会创建线程。

  • 这种策略避免了线程池停滞(lockups)。(当处理一些有内部依赖的请求时,可能线程池中的大部分线程都在等待一个线程释放锁,这时候就没有线程能处理新的任务了)

  • 这种策略需要搭配一个无界的maximumPoolSizeLong.MAX_VALUE)来避免拒绝新提交的任务。
    但是同时又默认的允许在线程池负载较大的时候无限制的创建线程。

6.2 无界队列,一直缓存任务

  • 使用无容量限制的LinkedBlockingQueue,这样当所有的core线程都在忙碌的情况下,新提交的任务会被添加到队列中等待

  • 这种情况下,线程池中的线程数目不会大于corePoolSize(maximumPoolSize这时就不生效了)

  • 这种策略适合在任务之间没有依赖的时候,任务在执行的过程中不会影响其他任务执行。

  • 这种方式可以平滑过多的请求,同时默认了任务队列中可能无限制的缓存任务。

6.3 有界队列

  • 使用容量有限的ArrayBlockingQueue来避免资源无限制的申请。如果设置了无界的maximumPoolSizeLong.MAX_VALUE)。但是这样会对线程池调优产生影响。

  • 队列容量和最大线程数之间会互相影响。

    • 使用容量较大的队列和较小的maximumPoolSize会导致低CPU利用率,带来额外的上下文切换。这样就人为的造成了低吞吐量。

    • 如果任务经常阻塞(I/O密集型任务)。a system may be able to schedule time for more threads than you otherwise allow.

    • 使用较小的队列一般要求更大的线程池大小,这样会提高CPU利用率,但是会带来额外的调度。可能会降低吞吐量。

  • Queue sizes and maximum pool sizes may be traded off for each other:

    • Using large queues and small pools minimizes CPU usage, OS resources, and context-switching overhead, but can lead to artificially low throughput.

    • If tasks frequently block (for example if they are I/O bound), a system may be able to schedule time for more threads than you otherwise allow.

    • Use of small queues generally requires larger pool sizes, which keeps CPUs busier but may encounter unacceptable scheduling overhead, which also decreases throughput.

6.4 任务拒绝策略

使用execute(Runnable)提交的任务会被拒绝,如果线程池已经关闭,或者线程池使用了有限的线程数目和工作队列容量(而且队列满了)。
任何一种情况该方法都会调用配置的RejectedExecutionHandler中的rejectedExecution(Runnable,ThreadPoolExecutor)方法。

默认提供了4种方式

  • ThreadPoolExecutor.AbortPolicy会抛出RejectedExecutionException

  • ThreadPoolExecutor.CallerRunsPolicy会让调用execute()方法的线程去运行任务。

  • ThreadPoolExecutor.DiscardPolicy直接抛弃任务

  • ThreadPoolExecutor.DiscardOldestPolicy如果线程池没有关闭,在工作队列头部的任务会被抛弃。

6.5 回调方法

  • beforeExecute(Thread,Runnable),afterExecute(Runnable,Throwable)在每个任务执行前,后都会被调用。可以用来维护执行环境。比如说重新初始化ThreadLocal,统计信息,或者增加日志

  • terminated方法可以被重载来添加一些需要在线程池关闭时的操作。

  • 如果回调方法抛出异常,线程池内部的工作线程会终止。

6.6 队列维护

  • getQueue()方法能拿到工作队列,来增加一些监控和Debug的功能。除了以上的用途,及其不推荐使用该方法来拿到工作队列去做别的事情。

  • 当大量的缓存任务被取消时remove(Runnable)purge可以用来帮助
    清理队列

6.7 Finalization

在程序中没有引用的线程池(垃圾),线程池中的线程不会自动终结。如果你需要保证用户忘记调用shutdown方法时,线程池中的线程也会被自动回收,
你需要设置恰当的keepAliveTime使用一个下界为0的core数目而且设置allowCoreThreadTimeOut(boolean)

©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 219,110评论 6 508
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 93,443评论 3 395
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 165,474评论 0 356
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 58,881评论 1 295
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 67,902评论 6 392
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 51,698评论 1 305
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 40,418评论 3 419
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 39,332评论 0 276
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 45,796评论 1 316
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 37,968评论 3 337
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 40,110评论 1 351
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 35,792评论 5 346
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 41,455评论 3 331
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 32,003评论 0 22
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 33,130评论 1 272
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 48,348评论 3 373
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 45,047评论 2 355

推荐阅读更多精彩内容

  • 【JAVA 线程】 线程 进程:是一个正在执行中的程序。每一个进程执行都有一个执行顺序。该顺序是一个执行路径,或者...
    Rtia阅读 2,768评论 2 20
  • 转自http://www.cnblogs.com/dolphin0520/p/3932921.html Java并...
    Allen_cyn阅读 1,906评论 0 4
  • 原文连接 在前面的文章中,我们使用线程的时候就去创建一个线程,这样实现起来非常简便,但是就会有一个问题: 如果并发...
    zjk_00阅读 636评论 0 1
  • 梦中楼阁 ——乐兮山人 梦中的午后 一缕阳光 倾泻在 那神秘的 幽暗的 ...
    34e4e27da4e1阅读 341评论 0 0
  • 今年九月份,被好友安利央视热播的纪录片《零零后》,看了一集,便再也停不下来。看的过程中感叹加心慌:几年前的世界还是...
    九月九层塔阅读 557评论 0 4