锦囊篇|一文摸懂AsyncTask
使用说明
/**
* AsyncTask存在三个泛型类型
* 1。Params:输入数据
* 2。Progress:类似于用于进度更新的返回值
* 3。Result:输出的数据
*/
public class MyTask extends AsyncTask<String, Integer, String> {
/**
* 后台操作
* @param strings
* @return
*/
@Override
protected String doInBackground(String... strings) {
return null;
}
/**
* 执行前的预处理
*/
@Override
protected void onPreExecute() {
super.onPreExecute();
}
/**
* 执行完成
* @param s
*/
@Override
protected void onPostExecute(String s) {
super.onPostExecute(s);
}
/**
* 刷新得到的新更新
* @param values
*/
@Override
protected void onProgressUpdate(Integer... values) {
super.onProgressUpdate(values);
}
/**
* 任务取消
* @param s
*/
@Override
protected void onCancelled(String s) {
super.onCancelled(s);
}
/**
* 任务取消
*/
@Override
protected void onCancelled() {
super.onCancelled();
}
}
而Async的执行流程如下图所示
MyTask task = new MyTask();
task.execute("。。");
一般我们在代码中只用执行excute()
的函数,在各个函数流程中给出相对应的操作。
对应的项目写在我的Github仓库[1]
原理分析
步骤一:构造函数
在使用期间我们是需要实例化这个对象的,那么必经的入口就是他的构造函数了。
public AsyncTask(@Nullable Looper callbackLooper) {
// 如果callbackLooper没有自行设置,会直接使用UI线程的Handler
mHandler = callbackLooper == null || callbackLooper == Looper.getMainLooper()
? getMainHandler()
: new Handler(callbackLooper);
mWorker = new WorkerRunnable<Params, Result>() {
public Result call() throws Exception {
mTaskInvoked.set(true);
Result result = null;
// 。。。
// 这里出现了我必须要重写的函数!!!
result = doInBackground(mParams);
// 。。。
// 把我们得到的数据传输了出去,发送到哪里呢?
postResult(result);
return result;
}
};
mFuture = new FutureTask<Result>(mWorker) {
@Override
protected void done() {
// 。。。
// 一个一定会执行的函数
postResultIfNotInvoked(get());
// 。。。
}
};
}
private void postResultIfNotInvoked(Result result) {
// 任务标记
final boolean wasTaskInvoked = mTaskInvoked.get();
// 任务为执行,则传递结果
if (!wasTaskInvoked) {
postResult(result);
}
}
在这里我看到的都是一些数据的初始化,其实就是对任务完成的出口发送消息的定义、数据如何进行传递的定义等等。
步骤二:执行 / execute()
public final AsyncTask<Params, Progress, Result> execute(Params... params) {
return executeOnExecutor(sDefaultExecutor, params);
}
进入执行的第一句话,我们就能够看到这样一个函数,从字面意思我就能够知道了,是将数据放入了一个线程池。 为了验证我们之前所说的执行流程我们先进入executeOnExecutor ()
的函数。
public final AsyncTask<Params, Progress, Result> executeOnExecutor(Executor exec,
Params... params) {
// 。。。。
// 验证了最开始的使用流程,excute执行后,调用的是onPreExecute
onPreExecute();
// 开始对任务进行了处理
mWorker.mParams = params;
exec.execute(mFuture);
return this;
}
回到我们的执行流程中,我们还没有了解我们用的线程池他是怎样的? 通过不断的函数调用,我们能够找到这样的一个线程池内部类。
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(); // 1
}
}
});
if (mActive == null) {
scheduleNext(); // 1
}
}
protected synchronized void scheduleNext() {
// 从任务队列中取出一个任务
if ((mActive = mTasks.poll()) != null) {
// 出现了另外一个线程池来进行执行????
THREAD_POOL_EXECUTOR.execute(mActive);
}
}
}
其他我们先并不予以关注,你是否看到了scheduleNext()
这个一定会被调用的函数呢?而且里面又出现了一个线程池。原来这个 THREAD_POOL_EXECUTOR
变量才是真正的执行动作的线程池,那怎么去看待上面的那个线程池呢?其实mTasks
这个变量已经告诉我们答案了,他是一个任务存储的队列,并且execute()
是一个同步函数,所以 SerialExecutor
确切的说是一个进行按序任务调度的线程池。这样也就证实了在很多博客中会说AsyncTask
是一个由两个线程池和一个Handler组成的。
调用顺序的验证
前面讲过了execute()
后面调用的函数是onPreExecute()
。而接下来的步骤就是doInBackground()
,回到先前的execute()
的代码中,我们知道会出现下面的代码
exec.execute(mFuture);
// 上方操作调用的函数
public static void execute(Runnable runnable) {
sDefaultExecutor.execute(runnable);
}
我们已经讲过了sDefaultExecutor
他是一个任务调度的线程池,他会将任务发送给THREAD_POOL_EXECUTOR
进行完成,而他完成的mFuture
其实也是一个全局变量,我在构造函数中已经提到过了。
mWorker = new WorkerRunnable<Params, Result>() {
public Result call() throws Exception {
mTaskInvoked.set(true);
Result result = null;
try {
Process.setThreadPriority(Process.THREAD_PRIORITY_BACKGROUND);
// 由线程池执行完成时,用于回调的借口
result = doInBackground(mParams);
Binder.flushPendingCommands();
} catch (Throwable tr) {
mCancelled.set(true);
throw tr;
} finally {
postResult(result);
}
return result;
}
};
mFuture = new FutureTask<Result>(mWorker) {
@Override
protected void done() {
try {
postResultIfNotInvoked(get());
} catch (InterruptedException e) {
android.util.Log.w(LOG_TAG, e);
} catch (ExecutionException e) {
throw new RuntimeException("An error occurred while executing doInBackground()",
e.getCause());
} catch (CancellationException e) {
postResultIfNotInvoked(null);
}
}
};
这里给读者们看个全貌,作为最后的回调接口中,我们是否已经关注到了一个函数doInBackground()
这个函数呢? 目前为止我们已经完成了前三步,就差最后的一步onPostExecute()
的执行出现了,其实在上文就已经提到过了postResult(result)
这段代码,就是进行一个结果的提交也就对应着我们所说的onPostExecute()
。 我们通过深入了解可以知道,就是通过Handler
将一个数据传出去,这个时候既然结束了,那就对应的是一个finish()
函数。
private static class InternalHandler extends Handler {
public InternalHandler(Looper looper) {
super(looper);
}
@SuppressWarnings({"unchecked", "RawUseOfParameterizedType"})
@Override
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:
// 得到了publish的操作,来到这里操作数据。
result.mTask.onProgressUpdate(result.mData);
break;
}
}
}
// 被调用的finish函数
private void finish(Result result) {
if (isCancelled()) {
onCancelled(result);
} else {
onPostExecute(result);
}
mStatus = Status.FINISHED;
}
到这里,我们完完整整的验证了执行的流程。
总结
Q1:为什么AsyncTask
会引发内存泄漏问题?
A1:其实这个问题一个方面和Handler
同理,如果采用了UI
线程中的Looper
作为消息暂存的空间,那Activity
被销毁时同样的会因为消息没有没执行而发生内存泄漏。具体的分析见于锦囊篇|一文摸懂Handler[2]
另一个方面就是关于线程池的创建,public static final Executor THREAD_POOL_EXECUTOR;
,你能够看到是一个静态的变量,那么即便当Activity
被销毁时,还在运行的线程任务是不会被暂停的,这也就是造成了内存泄漏的第二个原因了。
参考资料
[1] Github仓库: https://github.com/ClericYi/MoNiAsyncTask
[2] 锦囊篇|一文摸懂Handler: https://juejin.im/post/5e4fa55f6fb9a07cb427d081
- 你应该使用 Python 管理 Cron 作业
- CSS3有哪些好用的属性?
- PHP数据结构(九) ——图的定义、存储与两种方式遍历
- 使用 React 和 Django REST Framework 构建你的网站
- 小程序中带图片modal的实现
- 号称「永远不会输钱」的马丁格尔策略
- 小程序中图片高度等比缩放
- 三分钟使用 Python 处理 Nginx 日志
- Python,Shell 和 三个标准文件
- 【微信官方】获取用户信息方案介绍
- 【实战】如何使用 Python 从 Redis 中删除 4000万 KEY
- [多图] DevOps 也要懂点 Excel
- [实战篇] Python 运维中使用并发
- PHP数据结构(十) ——有向无环图与拓扑算法
- JavaScript 教程
- JavaScript 编辑工具
- JavaScript 与HTML
- JavaScript 与Java
- JavaScript 数据结构
- JavaScript 基本数据类型
- JavaScript 特殊数据类型
- JavaScript 运算符
- JavaScript typeof 运算符
- JavaScript 表达式
- JavaScript 类型转换
- JavaScript 基本语法
- JavaScript 注释
- Javascript 基本处理流程
- Javascript 选择结构
- Javascript if 语句
- Javascript if 语句的嵌套
- Javascript switch 语句
- Javascript 循环结构
- Javascript 循环结构实例
- Javascript 跳转语句
- Javascript 控制语句总结
- Javascript 函数介绍
- Javascript 函数的定义
- Javascript 函数调用
- Javascript 几种特殊的函数
- JavaScript 内置函数简介
- Javascript eval() 函数
- Javascript isFinite() 函数
- Javascript isNaN() 函数
- parseInt() 与 parseFloat()
- escape() 与 unescape()
- Javascript 字符串介绍
- Javascript length属性
- javascript 字符串函数
- Javascript 日期对象简介
- Javascript 日期对象用途
- Date 对象属性和方法
- Javascript 数组是什么
- Javascript 创建数组
- Javascript 数组赋值与取值
- Javascript 数组属性和方法
- Flutter Widgets 之 AnimatedContainer
- Flutter Widgets 之 Opacity 和AnimatedOpacity
- 聊聊常见的服务(接口)认证授权
- Flutter Widgets 之 FutureBuilder
- [Hei-Ocelot-Gateway ].Net Core Api网关Ocelot的开箱即用版本
- Flutter Widgets 之 InkWell 和 Ink
- Flutter Widgets 之 BottomNavigationBar
- Flutter Widgets 之 PageView
- 笔试题:代码如何实现“百钱买百鸡”?
- Flutter Widgets 之 Dialog 对话框
- 全网最详细的一篇Flutter 尺寸限制类容器总结
- 一篇带你看懂Flutter叠加组件Stack
- Flutter 拖拽排序组件 ReorderableListView
- 女神节 | 程序员如何低调而又不失逼格
- Flutter 拖拽控件Draggable看这一篇就够了