Android进阶-线程池

在上一篇文章(为什么要学习) AsyncTask 原理 提到了线程池,那么现在来学习学习 Android 的线程池。那么来看看线程池有什么优点,或者说为什么要学习线程池。

  • 重用线程池中的线程,避免了新建和销毁线程的内存开销。
  • 能有效线程池的最大并发数,避免大量的线程之间因互相抢占系统资源而导致阻塞现象。
  • 能够对线程进行简单的管理,并提供定时执行以及指定间隔循环执行等功能。

基础线程池

常用的线程池有挺多的,首先来看看基础线程池 ThreadPoolExcutor ,其他常见线程池都是基于 ThreadPoolExcutor 去实现的。那么我们先从它的构造方法入手。

    public ThreadPoolExecutor(int corePoolSize,
                              int maximumPoolSize,
                              long keepAliveTime,
                              TimeUnit unit,
                              BlockingQueue<Runnable> workQueue,
                              ThreadFactory threadFactory) {
        this(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue,
             threadFactory, defaultHandler);
    }

参数:corePoolSize
线程池的核心线程数,默认情况下核心线程会一直存在,即便是线程处于闲置状态。
参数:maximumPoolSize
线程池所能容纳的最大线程数,当核心线程不够用时,就会开启非核心线程来处理任务,maximumPoolSize = corePoolSize + 非核心线程数
参数:keepAliveTime
当非核心线程处理完任务处于闲置闲置状态时,如果在一定时间范围内没有被重用,就会被销毁。而 keepAliveTime 就是前面所指的一定时间范围。
参数:unit
有了时间范围,当然要确定时间的单位。而这个参数就是描述时间范围的参数。这是一个枚举参数,常用的有:
TimeUnit.DAYS
TimeUnit.HOURS
TimeUnit.MINUTES
参数:workQueue
线程池的任务队列,线程池的 excute 方法提交的任务会进入这个队列。
参数:threadFactory
为线程池提供新建线程的方法--> newThread(Runnale r)

ThreadPoolExcutor 执行任务时大致遵循的规则:

  1. 如果线程池中的线程数量还没达到核心线程数,则新开启一个核心线程来执行任务
  2. 如果已经达到或者超过核心线程的数量,则会被插入到任务队列中,等待执行
  3. 如果任务队列已满,则会新开启一个非核心线程来执行任务。
  4. 如果线程数达到最大值,则会拒绝执行任务。

ok,解释了那么多还不如来 实践一下,下面看看小例子:

mExecutor = new ThreadPoolExecutor(3, 6, 1, TimeUnit.SECONDS, new ArrayBlockingQueue<Runnable>(5));//初始化 mExecutor 

fab.setOnClickListener(new View.OnClickListener() {//设置一个点击事件
    @Override
    public void onClick(View view) {
        num++;
        mExecutor.execute(new MyRunnable(String.valueOf(num)));
        Log.d(TAG, "队列中等待执行的任务数: "+String.valueOf(mExecutor.getPoolSize()));
        Log.d(TAG, "执行完毕是数量: "+String.valueOf(mExecutor.getCompletedTaskCount()));
    }
});
        

常用线程池

FixedThreadPool
这是一种只有核心线程的线程池,线程都不会被回收,而且意味着能更快地响应任务,并且任务队列也没有大小限制。
FixedThreadPool 实例化方法:

    public static ExecutorService newFixedThreadPool(int nThreads) {
        return new ThreadPoolExecutor(nThreads, nThreads,
                                      0L, TimeUnit.MILLISECONDS,
                                      new LinkedBlockingQueue<Runnable>());
    }

实例:

ExecutorService e = Executors.newFixedThreadPool(5);
e.execute(new MyRunnable(String.valueOf(num)));

CachedThreadPool
这是一种线程数不确定的线程池,由下面的实例化方法可以看出,核心线程为0,非核心线程为 Integer.MAX_VALUE ,这是一个很大的数。超时策略为 60 秒。另外,SynchronousQueue 是一个无法存储元素的队列,也就是说,每当有新任务,就会立即开启一个线程。而如果全部任务都处理完成,线程池中也可能存在 0 个线程的情况。所以,几乎不占用任何系统资源。
CachedThreadPool 实例化方法:

public static ExecutorService newCachedThreadPool() {
    return new ThreadPoolExecutor(0, Integer.MAX_VALUE,
                                  60L, TimeUnit.SECONDS,
                                  new SynchronousQueue<Runnable>());
}

实例:

ExecutorService e2 = Executors.newCachedThreadPool();
e2.execute(new MyRunnable(String.valueOf(num)));

ScheduledThreadPool
从下面的实例化方法可以看出,这是一个核心线程固定,非核心线程很大很大的一个线程池。DEFAULT_KEEPALIVE_MILLIS = 10L,也就是说超时策略为 10 毫秒。
实例化方法:

public ScheduledThreadPoolExecutor(int corePoolSize) {
    super(corePoolSize, Integer.MAX_VALUE,
          DEFAULT_KEEPALIVE_MILLIS, MILLISECONDS,
          new DelayedWorkQueue());
}

实例:

ExecutorService e3 = Executors.newScheduledThreadPool(5);
e3.execute(new MyRunnable(String.valueOf(num)));

SingleThreadPool
从下面的实例化方法中,可以看出,这个线程池,只有一个核心线程。它存在的意义就是确保所有任务都在同一个线程执行,使得这些任务不需要处理线程同步的问题。
实例化方法:

public static ExecutorService newSingleThreadExecutor() {
    return new FinalizableDelegatedExecutorService
        (new ThreadPoolExecutor(1, 1,
                                0L, TimeUnit.MILLISECONDS,
                                new LinkedBlockingQueue<Runnable>()));
}

实例:

ExecutorService e4 = Executors.newSingleThreadExecutor();
e4.execute(new MyRunnable(String.valueOf(num)));

总结

进过一系列的学习,对于线程池也是有了初步的了解,但是了解归了解,运用到实际开发中优势另外一回事。还得多与实际相结合。

参考文献:《Android开发艺术探索》

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

推荐阅读更多精彩内容