Java并发编程的艺术(十)——线程池(1)

线程池的作用

  1. 减少资源的开销 减少了每次创建线程、销毁线程的开销。
  2. 提高响应速度 每次请求到来时,由于线程的创建已经完成,故可以直接执行任务,因此提高了响应速度。
  3. 提高线程的可管理性 线程是一种稀缺资源,若不加以限制,不仅会占用大量资源,而且会影响系统的稳定性。 因此,线程池可以对线程的创建与停止、线程数量等等因素加以控制,使得线程在一种可控的范围内运行,不仅能保证系统稳定运行,而且方便性能调优。

线程池的实现原理

线程池一般由两种角色构成:多个工作线程 和 一个阻塞队列。

  • 工作线程 工作线程是一组已经处在运行中的线程,它们不断地向阻塞队列中领取任务执行。
  • 阻塞队列 阻塞队列用于存储工作线程来不及处理的任务。当工作线程都在执行任务时,到来的新任务就只能暂时在阻塞队列中存储。

ThreadPoolExecutor的使用

创建线程池

通过如下代码即可创建一个线程池:

new ThreadPoolExecutor(corePoolSize, maximumPoolSize, keepAliveTime, timeUnit, runnableTaskQueue, handler);
  • corePoolSize:基本线程数量 它表示你希望线程池达到的一个值。线程池会尽量把实际线程数量保持在这个值上下。
  • maximumPoolSize:最大线程数量 这是线程数量的上界。 如果实际线程数量达到这个值:
    1. 阻塞队列未满:任务存入阻塞队列等待执行
    2. 阻塞队列已满:调用饱和策略
  • keepAliveTime:空闲线程的存活时间 当实际线程数量超过corePoolSize时,若线程空闲的时间超过该值,就会被停止。 PS:当任务很多,且任务执行时间很短的情况下,可以将该值调大,提高线程利用率。
  • timeUnit:keepAliveTime的单位
  • runnableTaskQueue:任务队列 这是一个存放任务的阻塞队列,可以有如下几种选择:
    1. ArrayBlockingQueue 它是一个由数组实现的阻塞队列,FIFO。
    2. LinkedBlockingQueue 它是一个由链表实现的阻塞队列,FIFO。 吞吐量通常要高于ArrayBlockingQueue。 fixedThreadPool使用的阻塞队列就是它。 它是一个无界队列。
    3. SynchronousQueue 它是一个没有存储空间的阻塞队列,任务提交给它之后必须要交给一条工作线程处理;如果当前没有空闲的工作线程,则立即创建一条新的工作线程。 cachedThreadPool用的阻塞队列就是它。 它是一个无界队列。
    4. PriorityBlockingQueue 它是一个优先权阻塞队列。
  • handler:饱和策略 当实际线程数达到maximumPoolSize,并且阻塞队列已满时,就会调用饱和策略。 JDK1.5由四种饱和策略:
    1. AbortPolicy 默认。直接抛异常。
    2. CallerRunsPolicy 只用调用者所在的线程执行任务。
    3. DiscardOldestPolicy 丢弃任务队列中最久的任务。
    4. DiscardPolicy 丢弃当前任务。

提交任务

可以向ThreadPoolExecutor提交两种任务:Callable和Runnable。

  1. Callable 该类任务有返回结果,可以抛出异常。 通过submit函数提交,返回Future对象。 可通过get获取执行结果。
  2. Runnable 该类任务只执行,无法获取返回结果,并在执行过程中无法抛异常。 通过execute提交。

关闭线程池

关闭线程池有两种方式:shutdown和shutdownNow,关闭时,会遍历所有的线程,调用它们的interrupt函数中断线程。但这两种方式对于正在执行的线程处理方式不同。

  1. shutdown() 仅停止阻塞队列中等待的线程,那些正在执行的线程就会让他们执行结束。
  2. shutdownNow() 不仅会停止阻塞队列中的线程,而且会停止正在执行的线程。

ThreadPoolExecutor运行机制

当有请求到来时:

  1. 若当前实际线程数量 少于 corePoolSize,即使有空闲线程,也会创建一个新的工作线程;
  2. 若当前实际线程数量处于corePoolSize和maximumPoolSize之间,并且阻塞队列没满,则任务将被放入阻塞队列中等待执行;
  3. 若当前实际线程数量 小于 maximumPoolSize,但阻塞队列已满,则直接创建新线程处理任务;
  4. 若当前实际线程数量已经达到maximumPoolSize,并且阻塞队列已满,则使用饱和策略。

设置合理的线程池大小

任务一般可分为:CPU密集型、IO密集型、混合型,对于不同类型的任务需要分配不同大小的线程池。

  • CPU密集型任务 尽量使用较小的线程池,一般为CPU核心数+1。 因为CPU密集型任务使得CPU使用率很高,若开过多的线程数,只能增加上下文切换的次数,因此会带来额外的开销。
  • IO密集型任务 可以使用稍大的线程池,一般为2*CPU核心数。 IO密集型任务CPU使用率并不高,因此可以让CPU在等待IO的时候去处理别的任务,充分利用CPU时间。
  • 混合型任务 可以将任务分成IO密集型和CPU密集型任务,然后分别用不同的线程池去处理。 只要分完之后两个任务的执行时间相差不大,那么就会比串行执行来的高效。 因为如果划分之后两个任务执行时间相差甚远,那么先执行完的任务就要等后执行完的任务,最终的时间仍然取决于后执行完的任务,而且还要加上任务拆分与合并的开销,得不偿失。

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏Java Edge

操作系统之文件管理一、文件与文件系统二、文件控制块和文件目录三、文件的物理结构四、文件系统的实现五、文件系统实例(UNIX)六、UNIX文件系统一、文件系统实例(FAT)二、文件操作的实现三、文件系统

4006
来自专栏睿哥杂货铺

操作系统原理:How Linux Works(三):Memory

内存是计算机中与CPU进行沟通的桥梁,用于暂时存放CPU中的运算数据。Linux 内核的内存管理机制设计得非常精妙,对于 Linux 内核的性能有很大影响。在早...

2028
来自专栏CSDN技术头条

深入理解 Java 多线程核心知识:跳槽面试必备

多线程相对于其他 Java 知识点来讲,有一定的学习门槛,并且了解起来比较费劲。在平时工作中如若使用不当会出现数据错乱、执行效率低(还不如单线程去运行)或者死锁...

963
来自专栏小白安全

通过DVWA学习XSS

简介 这篇文章通过 dvwa 简单研究了三种类型的 xss,并且讲述了如何利用 xss 获取目标网站用户的 cookie。 dvwa反射型xss ...

3405
来自专栏刘爽的专栏

Linux 性能监控 : CPU 、Memory 、 IO 、Network

本文收集整理了Linux性能监控的方法,监控对象包括CPU 、Memory 、IO 、Network,并记录了良好状态指标,所使用的监控工具以及参数指标。

4.4K1
来自专栏everhad

Android代码分析工具lint学习

1 lint简介 1.1 概述 lint是随Android SDK自带的一个静态代码分析工具。它用来对Android工程的源文件进行检查,找出在正确性、安全、性...

2269
来自专栏Seebug漏洞平台

TP-LINK WR941N路由器研究

作者:Hcamael@知道创宇404实验室 之前看到了一个CVE, CVE-2017-13772 是TP-Link WR940N后台的RCE, 手头上正好有一个...

2806
来自专栏向前进

vue-cli脚手架npm相关文件解读(7)dev-server.js

系列文章传送门: 1、build/webpack.base.conf.js 2、build/webpack.prod.conf.js 3、build/webp...

4017
来自专栏文武兼修ing——机器学习与IC设计

基于Python的运动计费管理系统动机技术路线规划实现

动机 小伙伴们最近迷恋上羽毛球,组织了个小群,办了公用的运动卡用于开场,考虑不是每次活动都是全员参与,需要一个计费的系统来计算每个人需要交的费用。商讨后决定采用...

2848
来自专栏java一日一条

Java 线程池框架核心代码分析

多线程编程中,为每个任务分配一个线程是不现实的,线程创建的开销和资源消耗都是很高的。线程池应运而生,成为我们管理线程的利器。Java 通过Executor接口,...

601

扫码关注云+社区