深入了解AsyncTask工作原理

一、 AsyncTask简介

AsyncTask是一种轻量级的异步任务类,它可以在线程池中执行后台的任务,然后把执行的进度和最终结果传递给主线程并在主线程中更新UI。

private abstract class AsyncTask<Params, Progress, Result>

它提供了Params、Progress和Result这三个泛型参数,其中Params表示参数的类型,Progress表示后台任务执行进度的类型,而Result则表示后台任务的返回结果的类型。

AsyncTask提供了4个核心方法:

  1. preExecute() 主线程中执行,异步任务执行前会被调用
  1. doInBackground(Params...params) 线程池中执行,用于执行异步任务
  2. onProgressUpdate(Progress..values) 主线程执行,当后台任务执行进度发生改变时调用
  3. onPostExecute(Result result) 主线程执行,异步任务执行之后被调用

除了上述四个方法,AsyncTask还提供了onCancelled()方法,同样在主线程中执行,当异步任务被取消时,onCancelled()方法被调用。
下面提供一个实例:

private class DownloadFilesTask extends AsyncTask<URL, Integer, Long>{

    @Override
    protected Long doInBackground(URL... urls) {
        // 执行下载任务
        int count = urls.length;
        long totalSize = 0;
        for (int i=0; i<count; i++){
            totalSize += Downloader.downloadFile(urls[i]);
            // 当publishProgress被调用时,onProgressUpdate就被被调用,更新界面中的下载进度
            publishProgress((int)((i/(float)count)*100));
            // 判断下载任务是否被外部中断
            if (isCancelled()) break;
        }
        return totalSize;
    }
        
    @Override
    protected void onProgressUpdate(Integer... progress) {
        // 更新界面中的下载进度
        setProgressPercent(progress[0]);
    }
        
    @Override
    protected void onPostExecute(Long result) {
        // 当下载任务执行完成后执行
        showDialog("Downloaded" + result + "bytes");
    }
        
}

ps:doInBackground和onProgressUpdate方法它们的参数中均包含...的字样,在Java中表示参数的数量不定

当要执行上述下载任务是,可通过以下方式来完成:

new DownloadFilesTask().execute(url01, url02, url03);

使用AsyncTask需要注意:

  1. AsyncTask的类必须在主线程中加载
  1. AsyncTask的对象必须在主线程中创建
  2. execute必须在UI线程被调用
  3. 不要再程序中直接调用onPreExecute、onPostExecute、doInBackground、onProgressUpdate等方法
  4. 一个AsyncTask对象只能执行一次,即只调用一次excute方法,否则会报运行时异常

二、 AsyncTask的工作原理

为了分析AsyncTask,我们得从AsyncTask的源码入手,首先从它的execute方法开始分析:

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

execute方法又会执行executeOnExecutor方法

@MainThread
public final AsyncTask<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)");
       }
    }

    mStatus = Status.RUNNING;

    onPreExecute();

    mWorker.mParams = params;
    exec.execute(mFuture);

    return this;
}

在executeOnExecutor方法中首先会判断此AsyncTask是否已经在执行或者已经执行完毕,这就是为什么一个AsyncTask对象只能执行一次,即只调用一次excute方法,否则会报运行时异常
如果可以运行,则onPreExecute()方法会首先被调用,然后线程池exec(sDefaultExecutor)开始执行mFuture

mFuture一个FutureTask对象,在new AsyncTask()方法中系统会将AsyncTask的Params参数封装成FutureTask对象,FutureTask是一个并发类,这里充当Runnable的作用

接下来看sDefaultExecutor的execute()方法:

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有两个线程池(SerialExecutor和THREAD_POOL_EXECUTOR)和一个Handler
(InternalHandler),其中线程池SerialExecutor用于任务的排队,而线程池THREAD_POOL_EXECUTOR用于真正地执行任务,InternalHandler用于将执行环境从线程池切换到主线程

从源码可以看出,SerialExecutor的execute方法首先把FutureTask对象插入到任务队列mTasks中,如果这个时候没有正在活动的AsyncTask任务,那么就会调用SerialExecutor的scheduleNext方法来执行下一个AsyncTask任务。当一个AsyncTask任务执行完后,AsyncTask会继续执行其他任务直到所有任务都被执行为止,从这一点可以看出,在默认情况下,AsyncTask是串行执行的

接下里,要看FutureTask的run()方法,run()的方法里会调用mWorker的call()方法,因此mWoker的call()方法最终会在线程池执行:

mWorker = new WorkerRunnable<Params, Result>() {
    public Result call() throws Exception {
        mTaskInvoked.set(true);

         Process.setThreadPriority(Process.THREAD_PRIORITY_BACKGROUND);
         //noinspection unchecked
         Result result = doInBackground(mParams);
         Binder.flushPendingCommands();
         return postResult(result);
    }
};

这样就一目了然了,在mWorker的call方法中,首先将mTaskInvoked设为true,表示当前任务已经被调用过了,然后执行Async的doInBackground方法,接着将其返回值传递给postResult方法,它的实现如下:

private Result postResult(Result result) {
    @SuppressWarnings("unchecked")
    Message message = getHandler().obtainMessage(MESSAGE_POST_RESULT,
        new AsyncTaskResult<Result>(this, result));
    message.sendToTarget();
    return result;
}

在上面代码中,postResult方法会通过Handler发送一个MESSAGE_POST_RESULT的消息,这个Handler的定义如下:

private static Handler getHandler() {
    synchronized (AsyncTask.class) {
        if (sHandler == null) {
            sHandler = new InternalHandler();
        }
        return sHandler;
    }
}


private static class InternalHandler extends Handler {
    public InternalHandler() {
        super(Looper.getMainLooper());
    }

    @SuppressWarnings({"unchecked", "RawUseOfParameterizedType"})
    @Override
    public void handleMessage(Message msg) {
        AsyncTaskResult<?> result = (AsyncTaskResult<?>) msg.obj;
        switch (msg.what) {
            case MESSAGE_POST_RESULT:
                // There is only one result
                result.mTask.finish(result.mData[0]);
                break;
            case MESSAGE_POST_PROGRESS:
                result.mTask.onProgressUpdate(result.mData);
                break;
        }
     }
}

可以发现,这里的Handler对象是一个静态的Handler对象,为了能够将执行环境切换到主线程,这就要求这个Handler必须在主线程中创建。由于静态成员会在加载类的时候进行初始化,因此这就要求AsyncTask的类必须在主线程中加载,否则同一个进程中的AsyncTask都将无法正常工作。Handler收到MESSAGE_POST_RESULT消息后会调用AsyncTask的finish方法:

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

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

最后附上自己画的一副粗糙的图,into指进入函数内部,next代表下一个方法

源于《Android开发艺术探索》

三、 AsyncTask思考

多个AsyncTask任务是串行还是并行?

根据我们上面的源码,多个AsyncTask任务是串行执行的(Android3.0版本过后)。
如果需要并行执行,则只需要调用executeOnExecutor(Executor)函数,并把参数设置为并行执行即可。即创建一个单独的线程池(Executors.newCachedThreadPool())。或者最简单的方法法就是使用
executeOnExecutor(AsyncTask.THREAD_POOL_EXECUTOR),这样起码不用等到前面的都结束了再执行了。 executeOnExecutor(AsyncTask.SERIAL_EXECUTOR)则与execute()是一样的。

AsyncTask容易引发内存泄漏

如果AsyncTask被声明为Activity的非静态的内部类,那么AsyncTask会保留一个对创建了AsyncTask的Activity的引用。如果Activity已经被销毁,AsyncTask的后台线程还在执行,它将继续在内存里保留这个引用,导致Activity无法被回收,引起内存泄露。

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

推荐阅读更多精彩内容

  • Android Handler机制系列文章整体内容如下: Android Handler机制1之ThreadAnd...
    隔壁老李头阅读 3,175评论 1 15
  • Android开发者:你真的会用AsyncTask吗? 导读.1 在Android应用开发中,我们需要时刻注意保证...
    cxm11阅读 2,697评论 0 29
  • Android中的线程 线程,在Android中是非常重要的,主线程处理UI界面,子线程处理耗时操作。如果在主线程...
    shenhuniurou阅读 748评论 0 3
  • 大家早上好!昨天第一天分享结束以后看到朋友的留言和发的一些感悟,给了我很多的信心,让我相信,即使做这样的小事...
    杜白云飞阅读 3,356评论 0 1
  • 2017年6月1号,今天我终于放弃了对父亲的挽留。父亲在一个礼拜前急性肾衰竭,左肾是一直不好,现在右肾也跟着遭殃,...
    柬埔寨庄稼汉阅读 239评论 0 0