博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
Android 中的线程池
阅读量:5948 次
发布时间:2019-06-19

本文共 2277 字,大约阅读时间需要 7 分钟。

为什么使用线程池?

1、重用线程,防止频繁的创建销毁线程所带来的时间和资源等性能损耗。 2、有效的控制最大线程并发数,防止大量线程抢夺系统资源引起卡顿,合理利用系统资源。 3、对线程进行简单管理、以及线程间更好的协作工作

Android 中有哪几种线程池?

实际意义上我们所说的几种常用线程池都是 Java 封装好,都在 Executors 这个工厂类里面了,笔者使用的是 JDK8 所以发现里面有六种线程池,接下来分别介绍下

1. FixedThreadPool

数量固定的核心线程池,当线程池处于空闲时线程也不会被回收,除非线程被关闭了。如果所有线程都在运行中,再有新任务添加时新任务会处于等在状态,知道有线程空闲在运行。处于等待的任务没有数量上限

2. CachedThreadPool

这是一种线程数量不定的线程池,他只有非核心线程,线程池如果没有空闲线程,会随时创建新的线程来工作,如果空下来的线程空闲时长超过 60 秒,则会被回收。他在长时间不工作的时候内部是没有任何线程的,也就是不消耗任何资源

3. SingleThreadExecutor

只有一个核心线程的线程池,所有任务都要排队等待由唯一的一个核心线程来处理,处于等待的任务队列个数没有上限

4. ScheduledThreadPool

这是一个核心线程数量固定,非核心线程没有上限的线程池,非核心线程闲置时间超过 10 秒就会被回收(不同版本 JDK 可能不同),并且他的等待队列只有 16 个。并且支持定时及周期性任务执行。

5. SingleThreadScheduledExecutor

就是一个只有一个核心线程的 ScheduledThreadPool 线程池

6. WorkStealingPool

创建持有足够线程的线程池来支持给定的并行级别,并通过使用多个队列,减少竞争,它需要传一个并行数量,如果不传,则被设定为默认的CPU数量

自定义线程池

接下来上面提到的核心线程、非核心线程是什么,还有上面线程池的实现。 上面所有的线程池都是通过以下两个类创建的

一、 先说一说 ThreadPoolExecutor

public ThreadPoolExecutor(    int corePoolSize,    int maximumPoolSize,    long keepAliveTime,    TimeUnit unit,    BlockingQueue
workQueue) { this(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue, Executors.defaultThreadFactory(), defaultHandler);}复制代码

看一看各项参数

  • corePoolSize:线程池的核心线程数
  • maximumPoolSize:线程池中允许的最大线程数(maximumPoolSize-corePoolSize = 非核心线程)
  • keepAliveTime:空闲线程结束的超时时间(如果 allowCoreThreadTimeOut 属性设置为 true 核心线程闲置 keepAliveTime 时间以上也会被回收,false 则不会回收)
  • unit:是一个枚举,它表示的是 keepAliveTime 的单位
  • workQueue:工作队列,用于任务的存放

运行流程

  1. 线程池创建的时候里面不会有任何线程
  2. 如果正在运行的线程数量小于 corePoolSize,那么马上创建线程运行这个任务;
  3. 如果正在运行的线程数量大于或等于 corePoolSize,那么将这个任务放入队列;
  4. 如果这时候队列满了,而且正在运行的线程数量小于 maximumPoolSize,那么还是要创建非核心线程立刻运行这个任务;
  5. 如果队列满了,而且正在运行的线程数量大于或等于 maximumPoolSize,那么线程池会抛出异常RejectExecutionException。

我们上面说的 FixedThreadPool、CachedThreadPool、SingleThreadExecutor、ScheduledThreadPool、SingleThreadScheduledExecutor 都是通过 ThreadPoolExecutor 创建的,好奇的人可以看一下源码。

二、 ForkJoinPool

ForkJoinPool 是JDK 7加入的一个线程池类。Fork/Join 技术是分治算法(Divide-and-Conquer)的并行实现,它是一项可以获得良好的并行性能的简单且高效的设计技术。目的是为了帮助我们更好地利用多处理器带来的好处,使用所有可用的运算能力来提升应用的性能。我们常用的数组工具类 Arrays 在JDK 8之后新增的并行排序方法(parallelSort)就运用了 ForkJoinPool 的特性,还有 ConcurrentHashMap 在JDK 8之后添加的函数式方法(如forEach等)也有运用。

我们上面说的 WorkStealingPool 都是通过 ForkJoinPool 创建的。

这个知识点比较复杂大家可以参考其他博客

转载地址:http://gqdxx.baihongyu.com/

你可能感兴趣的文章
【290】Python 函数
查看>>
godaddy域名转发(域名跳转)设置教程
查看>>
silverlight学习布局之:布局stackpanel
查看>>
理解并自定义HttpHandler
查看>>
从前后端分离到GraphQL,携程如何用Node实现?\n
查看>>
JavaScript标准库系列——RegExp对象(三)
查看>>
Linux Namespace系列(09):利用Namespace创建一个简单可用的容器
查看>>
oracle中create table with as和insert into with as语句
查看>>
kafka连接异常
查看>>
11g废弃的Hint - BYPASS_UJVC
查看>>
为什么工业控制系统需要安全防护?
查看>>
Mongodb部署记录[3]-主从搭建
查看>>
hive sql操作
查看>>
tomcat 深度优化
查看>>
127 - "Accordian" Patience
查看>>
阿里云CentOS7安装Oracle11GR2
查看>>
nginc+memcache
查看>>
php正则匹配utf-8编码的中文汉字
查看>>
MemCache在Windows环境下的搭建及启动
查看>>
linux下crontab实现定时服务详解
查看>>