android多线程之AsyncTask源码分析

在有关线程的操作中一定要记住两点:

1、不能在UI线程中执行耗时的操作

2、不能在非主线程中更新UI界面


一、AsyncTask简介

AsyncTask封装了线程池和Handler,是Android的一个轻量级的异步类,它可以在线程池中执行后台操作,然后把执行的进度和结果通过Handler传递给主线程并在主线程里面更新UI。可以方便开发者实现异步操作。


二、AsyncTask用法和示例

1、用法

AsyncTask是一个抽象的泛型类,提供了Params、Progress、Result三个泛型参数

public abstract class AsyncTask<Params, Progress, Result>(){}

Params:需要传入参数的类型
Progress:后台任务的执行进度的类型
Result:后台任务返回结果的类型

AsyncTask提供了4个核心的方法,分别是:

1. OnPreExecute(), 在主线程中执行,在异步任务之前,此方法被调用一般做一些准备性的工作;

2. doInBackground(Params...params),在线程池中执行,用于执行异步任务,params表示异步任务的传入参数,此方法会调用publshProgress()来更新任务进度,publshProgress()会调用onProgressupdate(),会返回计算结果给onPostExecute().

3. onProgressUpdate(Progress...value),在主线程中执行,后台执行任务的进度有变化时被调用。

4. onPostExecute(Result result), 在主线程中执行,在异步任务执行之后,此方法会被调用,result为后台任务的返回值,即doInBackground()的返回值。

2、示例

public class DownloadFilesTask extends AsyncTask<URL, Integer, Long>{
    protected Long doInBackground(URL...url){
        int count = url.length;
        long totalSize = 0;
        for(int i = 0; i< count; i++){
            totalSize += DownloadFile(url[i]);
            publishProgress((int) (i/(float)count)*1000);
            if(isCancelled){
                break;
            }
        }
    }
    
    protected void onProgressUpdate(Integer...progress){
        setProgressPercent(progress[0]);
    }

    protected void onPostExecute(Long result){
        showDialog("bytes"+result);
    }
}

在DownloadFileTask中,doInBackground()执行下载任务并通过publishProgress()来更新进度,同时还会调用isCancelled()判断下载任务是否被取消。下载任务完成后doInBackground()会返回结果。publishProgress()被执行了调用onProgressUpdate()方法更新进度。当下载任务完成后onPostExecute()就会被调用,在主线程中做一些改变。


三、AsyncTask的限制

1. AsyncTask的类必须在主线程里加载;

2. AsyncTask的对象必须在主线程中调用;

3. execute方法必须在UI线程调用;

4. 不要在程序中直接调用onPreExecute()、onPostExecute()、doInBackground()、和onProgressUpdate();

5. 一个AsyncTask对象只能执行一次,即只能调用一次execute(),否则会报运行时异常;

三、AsyncTask工作原理

列表内容分析AsyncTask原理,先从execute()开始,execute()调用了executor(),源码实现如下:

public final AsyncTask<Params, Progress, Result> execute(Params...params){
    return executeOnExecutor(sDefaultExecutor params);
}

public final AsyncTask<Params, Progress, Result> executeOnExecutor(Executorexec, 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 is already finishing.")
        }
    }
    mStatus = Status.RUNNING;
    onPreExecute();
    mWorker.mParams = params;
    exec.execute(mFuture);
    return this;
}

sDefaultExecutor实际上是一个串行的线程池,一个进程的所有的线程都在这个串行的线程池里面排队,在executor()方法中, AsyncTask的onProExecute() 最先执行,然后线程池开始执行。

public static final Executor SERIAL_EXECUTOR = new SerialExecutor();

private static volatile Executor sDefaultExecutor = SERIAL_EXECUTOR;

private static class SerialExecutor implements Executor {
    final ArrayDeque<Runnable> mTasks = new ArrayDeque<Runnable>();
    Runnable mActive;
    public synchronized void execute (final Runnable r){
        mTasks.offer(new Runnable(){
            public void run(){
                try{
                    r.run();
                }finally{
                    scheduleNext();
                }
            }
        });
        if(mActive  == null){
            scheduleNext();
        }
    }
    
    protected synchronized void scheduleNext(){
        if(mActive = mTasks.poll() != null){
            THREAD_POOL_EXECUTOR.execute(mActive);
        }
    }
}

系统把AsyncTask的Params参数封装为FutureTask对象,Future是一个并发类,充当Runnable的作用,接着这个FutureTask会交给SerialExecutor的execute方法去处理,SerialExecutor的execute方法会把FutureTask插入到mTask任务队列中,如果没有正在执行的任务,那么就会调用SerialExecutor的scheduleNext方法来执行下一个AsyncTask任务,同时当一个任务执行完后,AsyncTask会继续调用其他任务直到所有任务都被执行完。

AsyncTask有两个线程池,SerialExecutor 和THREAD_POOL_EXECUTOR和一个Handler(InternalHandler),SerialExecutor用于任务的排队,而THREAD_POOL_EXECUTOR用于真正的执行任务,而InternalHandler用于将执行环境从线程池切换到主线程。

mWorker = new WorkerRunnable<Params, Result>(){
    public Result call() throws Exception{
        mTaskInvoked.set(true);
        Process.setThreadPriority(Process.THREAD_PRIORITY_BACKGROUND);
        return postResult(donInBackground(mParams));
    }
};

在mWorker的call方法中将mTaskInvoked设为true,表示当前任务已经被调用了,然后执行doInBackground方法,接着返回值传递给postResult方法。

private Result postResult (Result result){
    Message message = sHandler.obtainMessage(MESSAGE_POST_RESULT, new AsyncTaskResult<Result>(this, result));
    message.sendToTarget();
    return result;
}

postResult方法会通过sHandler发送一个MESSAGE_POST_RESULT的消息,这个sHandler的定义如下:

private static final InternalHandler sHandler = new InternalHandler();

private static class InternalHandler extends Handler{
    public void handleMessage(Message msg){
        AsyncTaskResult result = (AsyncTaskResult)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;
        }
    }
}

sHandler是一个静态的Handler对象,为了能够将执行环境切换到主线程,这就要求sHandler必须是在主线程中创建。由于静态成员在加载类的时候进行初始化,这就要求AsyncTask的类必须在主线程中加载。sHandler收到MESSAGE_POST_RESULT这个消息后会调用AsyncTask的finish方法。

private void finish(Result result){
    if(isCancelled()){
        onCancelled(result);
    } else {
        onPostExecute(result);
    }
    mStatus = Status.FINISHED;
}

如果AsyncTask被取消执行了,那么就会调用onCanedlled方法,否则就会调用onPostExecute方法,doInBackground的返回结果传递给onPostExecute方法。到这里AsyncTask的整个工作过程就分析完毕了。

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

推荐阅读更多精彩内容