文档章节

Thread并发请求封装——深入理解AsyncTask类

kymjs张涛
 kymjs张涛
发布于 2014/09/15 15:38
字数 1549
阅读 2892
收藏 27


在Android开发中,由于不能再UI线程中做耗时操作,常常需要开启线程来做一些操作。但是这样一来就产生了一个问题,就是大量的线程并发执行,造成了线程维护的开销进而使得代码质量下降手机发烫又耗电。让我们来看一下KJFrameForAndroid框架(http://git.oschina.net/kymjs/KJFrameForAndroid)是如何解决这个问题的。

其实Android提供了一套专门用于异步处理的类,就是我们熟悉又模式的AsynTask类。
AsynTask类就是对Thread类的一个封装,并且加入了一些新的方法。那么我们先来看一下它对于Thread请求的一系列管理与封装。
在jdk中有这样一个集合类叫:BlockingQueue<>它是一个 Queue<E>的子类,支持两个附加操作的 Queue,这两个操作是:获取元素时等待队列变为非空,以及存储元素时等待空间变得可用。
BlockingQueue 方法以四种形式出现,对于不能立即满足但可能在将来某一时刻可以满足的操作,这四种形式的处理方式不同:第一种是抛出一个异常,第二种是返回一个特殊值(null 或 false,具体取决于操作),第三种是在操作可以成功前,无限期地阻塞当前线程,第四种是在放弃前只在给定的最大时间限制内阻塞。


我们来看一下在jdk中关于这个类的介绍:

BlockingQueue 不接受 null 元素。试图 add、put 或 offer 一个 null 元素时,某些实现会抛出 NullPointerException。null 被用作指示 poll 操作失败的警戒值。

好,为什么要讲这个集合类呢?因为这与我们接下来要讲的线程池维护有着莫大的关系。

    // 静态阻塞式队列,用来存放待执行的任务,初始容量:8个
    private static final BlockingQueue<Runnable> mPoolWorkQueue = new LinkedBlockingQueue<Runnable>(8);

这里是KJFrameForAndroid开发框架中对于线程队列的维护对象,通过这个线程队列将所有线程放置在一个静态阻塞式队列中保存起来。
然而,仅仅是保存起来还不够,因为线程需要执行,我们必须要让线程进入到CPU工作间才行,这时KJFrameForAndroid使用了jdk中的另一个类ThreadPoolExecutor来管理并使用并发启动这些线程
来看一下在KJFrameForAndroid中对于这个类对象的创建

    /**
     * 并发线程池任务执行器,可以用来并行执行任务<br>
     * 与mSerialExecutor(串行)相对应
     */
    public static final Executor mThreadPoolExecutor = new ThreadPoolExecutor(
            CORE_POOL_SIZE, MAXIMUM_POOL_SIZE, KEEP_ALIVE,
            TimeUnit.SECONDS, mPoolWorkQueue, mThreadFactory);

通过注释,我们还可以看到KJFrameForAndroid框架其实还有一种并行执行线程的方式,这里暂时不讲,我们看看这个类的构造方法在jdk中的解释:

那么至此我们有了并发任务执行器和线程池队列,最后就只需要将线程执行起来就行了。ThreadPoolExecutor类是一个实现了执行器Executor接口的类,那么它也就有一个execute方法去执行线程,我们所要做的就是调用这个类来执行它就可以了。

接下来我们来看一下如何让线程执行完成后又回到UI线程去做界面处理的。

还是看源码,以下是摘自KJFrameForAndroid开源框架中的一段代码:

/*********************** start 一个完整的执行周期 ***************************/
    /**
     * 在doInBackground之前调用,用来做初始化工作 所在线程:UI线程
     */
    protected void onPreExecute() {}
    /**
     * 这个方法是我们必须要重写的,用来做后台计算 所在线程:后台线程
     */
    protected abstract Result doInBackground(Params... params);
    /**
     * 打印后台计算进度,onProgressUpdate会被调用<br>
     * 使用内部handle发送一个进度消息,让onProgressUpdate被调用
     */
    protected final void publishProgress(Progress... values) {
        if (!isCancelled()) {
            mHandler.obtainMessage(MESSAGE_POST_PROGRESS,
                    new KJTaskResult<Progress>(this, values))
                    .sendToTarget();
        }
    }
    /**
     * 在publishProgress之后调用,用来更新计算进度 所在线程:UI线程
     */
    protected void onProgressUpdate(Progress... values) {}
    /**
     * 任务结束的时候会进行判断:如果任务没有被取消,则调用onPostExecute;否则调用onCancelled
     */
    private void finish(Result result) {
        if (isCancelled()) {
            onCancelled(result);
        } else {
            onPostExecute(result);
        }
        mStatus = Status.FINISHED;
    }
    /**
     * 在doInBackground之后调用,用来接受后台计算结果更新UI 所在线程:UI线程
     */
    protected void onPostExecute(Result result) {}
    /**
     * 所在线程:UI线程<br>
     * doInBackground执行结束并且{@link #cancel(boolean)} 被调用。<br>
     * 如果本函数被调用则表示任务已被取消,这个时候onPostExecute不会再被调用。
     */
    protected void onCancelled(Result result) {}
    /*********************** end 一个完整的执行周期 ***************************/

在这里我们看到了三个非常熟悉的函数:doInBackground、onPostExecute、onProgressUpdate
没错,这三个函数正式SyncTask中被我们使用的三个方法(如果你还不知道,请搜索Android开发中SyncTask用法)接着我们再看看他们是如何被调用的:
这里声明了一个线程任务被执行的方法,实际上也就是doInBackground、被调用的方法:

/**
     * 必须在UI线程调用此方法<br>
     * 通过这个方法我们可以自定义KJTaskExecutor的执行方式,串行or并行,甚至可以采用自己的Executor 为了实现并行,
     * asyncTask.executeOnExecutor(KJTaskExecutor.mThreadPoolExecutor, params);
     */
    public final KJTaskExecutor<Params, Progress, Result> executeOnExecutor(
            Executor exec, Params... params) {
        if (mStatus != Status.PENDING) {
            switch (mStatus) {
            case RUNNING:
                throw new IllegalStateException(
                        "Cannot execute task:"
                                + " the task is already running.");
            case FINISHED:
                throw new IllegalStateException(
                        "Cannot execute task:"
                                + " the task has already been executed "
                                + "(a task can be executed only once)");
            default:
                break;
            }
        }
        mStatus = Status.RUNNING;
        onPreExecute();
        mWorker.mParams = params;
        exec.execute(mFuture);// 原理{@link #execute(Runnable runnable)}
        // 接着会有#onProgressUpdate被调用,最后是#onPostExecute
        return this;
    }

而onProgressUpdate实际上是在这个handle中被调用了。

/**
     * KJTaskExecutor内部Handler,用来发送后台计算进度更新消息和计算完成消息
     */
    private static class InternalHandler extends Handler {
        @Override
        @SuppressWarnings({ "unchecked", "rawtypes" })
        public void handleMessage(Message msg) {
            KJTaskResult result = (KJTaskResult) msg.obj;
            switch (msg.what) {
            case MESSAGE_POST_RESULT:
                result.mTask.finish(result.mData[0]);
                break;
            case MESSAGE_POST_PROGRESS:
                result.mTask.onProgressUpdate(result.mData);
                break;
            }
        }
    }

有关本类的完整代码可以查看http://git.oschina.net/kymjs/KJFrameForAndroid/blob/master/KJFrame/src/org/kymjs/kjframe/http/core/KJAsyncTask.java

© 著作权归作者所有

kymjs张涛

kymjs张涛

粉丝 511
博文 64
码字总数 76485
作品 4
普陀
Android工程师
私信 提问
加载中

评论(4)

杰森斯坦森
杰森斯坦森

引用来自“Butrs_Bees”的评论

楼主可以看看KJFrameForAndroid这个框架

引用来自“isaacchen”的评论

引用来自“kymjs_张涛”的评论

呵呵,我就是这个框架的作者
所以我才擦汗
kymjs张涛
kymjs张涛 博主

引用来自“Butrs_Bees”的评论

楼主可以看看KJFrameForAndroid这个框架

引用来自“isaacchen”的评论

呵呵,我就是这个框架的作者
杰森斯坦森
杰森斯坦森

引用来自“Butrs_Bees”的评论

楼主可以看看KJFrameForAndroid这个框架
Butrs_Bees
Butrs_Bees
楼主可以看看KJFrameForAndroid这个框架
一套完善的Android异步任务类

今天向大家介绍一个很有用的异步任务类处理类,分别包含了AsyncTask各个环节中的异常处理、大量并发执行而不发生异常、字符串数据缓存等功能。并且感谢@马天宇(http://litesuits.com/)的合作...

kymjs张涛
2014/11/30
6.8K
19
android基础知识02——线程安全5: AsyncTask

android的UI操作不是线程安全的,同时也只有主线程才能够操作UI,同时主线程对于UI操作有一定的时间限制(最长5秒)。为了能够做一些比较耗时的操作(比如下载、打开大文件等),android提供...

迷途d书童
2012/03/23
1K
0
关于AsyncTask的一次深度解析

前言 任何一个Android 开发者对AsnycTask 都应该不陌生;使用AsyncTask可以很方便的异步处理耗时操作;AsyncTask内部对Handler和Thread进行了封装,简化了Handler的使用方式,使用起来非常方...

IAM四十二
2018/10/24
0
0
Android异步加载全解析之使用AsyncTask

Android异步加载全解析之使用AsyncTask 概述 既然前面提到了多线程,就不得不提到线程池,通过线程池,不仅可以对并发线程进行管理,更可以提高他们执行的效率,优化整个App。当然我们可以自...

eclipse_xu
2015/03/19
0
0
android AsyncTask 的分析与运用

线程 在Android当中,通常将线程分为两种,一种叫做Main Thread,除了Main Thread之外的线程都可称为Worker Thread。 当一个应用程序运行的时候,Android操作系统就会给该应用程序启动一个线...

ostracod
2017/03/28
0
0

没有更多内容

加载失败,请刷新页面

加载更多

聊聊Tomcat中的连接器(Connector)

上期回顾 上一篇文章《Tomcat在SpringBoot中是如何启动的》从main方法启动说起,窥探了SpringBoot是如何启动Tomcat的,在分析Tomcat中我们重点提到了,Tomcat主要包括2个组件,连接器(Conne...

木木匠
29分钟前
1
0
OSChina 周一乱弹 —— 熟悉的味道,难道这就是恋爱的感觉

Osc乱弹歌单(2019)请戳(这里) 【今日歌曲】 @xiaoshiyue :好久没分享歌了分享张碧晨的单曲《今后我与自己流浪》 《今后我与自己流浪》- 张碧晨 手机党少年们想听歌,请使劲儿戳(这里)...

小小编辑
今天
1K
19
SpringBoot中 集成 redisTemplate 对 Redis 的操作(二)

SpringBoot中 集成 redisTemplate 对 Redis 的操作(二) List 类型的操作 1、 向列表左侧添加数据 Long leftPush = redisTemplate.opsForList().leftPush("name", name); 2、 向列表右......

TcWong
今天
28
0
排序––快速排序(二)

根据排序––快速排序(一)的描述,现准备写一个快速排序的主体框架: 1、首先需要设置一个枢轴元素即setPivot(int i); 2、然后需要与枢轴元素进行比较即int comparePivot(int j); 3、最后...

FAT_mt
昨天
4
0
mysql概览

学习知识,首先要有一个总体的认识。以下为mysql概览 1-架构图 2-Detail csdn |简书 | 头条 | SegmentFault 思否 | 掘金 | 开源中国 |

程序员深夜写bug
昨天
12
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部