Android学习笔记11-Service后台服务(2)
Android学习笔记11-Service后台服务(二)-异步消息处理机制和AsyncTask
一,消息机制的简介
在Android中使用消息机制,首先想到的是Handler,Handler是Android消息机制的上层接口,Handler的使用方法很简单,通过它可以把一个任务切换到Handler所在的线程中去执行,通常,Handler的使用场景就是更新UI。
如在上一章中所用的例子
public class MainActivity extends AppCompatActivity implements View.OnClickListener {
private TextView text;
public static final int UPDATE_TEXT = 1;
private Handler handler = new Handler() {
@Override
public void handleMessage(Message msg) {
switch (msg.what) {
case UPDATE_TEXT:
//在这里可以进行UI操作
text.setText("Nice to meet you");
break;
default:break;
}
}
};
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_main);
//声明控件
Button changeText = (Button) findViewById(R.id.change_text);
text = (TextView) findViewById(R.id.text);
//设置点击监听器
changeText.setOnClickListener(this);
}
/**
* 设置点击事件
*/
@Override
public void onClick(View v) {
switch (v.getId()) {
case R.id.change_text:
Message message = new Message();
message.what = UPDATE_TEXT;
handler.sendMessage(message);
break;
default:break;
}
}
}
在子线程中,进行耗时操作,执行完操作后,发送消息,通知主线程更新UI,这便是Android消息机制的典型应用场景.
二,消息机制的模型
消息机制主要包含
-
Message:需要传递的消息,可以传递数据(what,arg1,agr2,obj)
-
MessageQueue: 消息队列。但是它的内部实现结构采用的的单链表的形式,因为单链表在插入和删除的操作上比较有优势。它的主要功能是通过MessageQueue.enqueueMessage 方法向消息池中投递消息,和用 MessageQueue.next 方法取走消息池中的消息。每个线程只有一个MessageQueue对象
-
Handler:消息辅助类,主要功能是向消息池 发送消息事件(Handler.sendMessage)和处理相应的消息事件(Handler.handleMessage)
-
Looper:它是每个线程中的MessageQueue的管家,调用Looper.loop()方法,就会进入无限循环中,每当发现MessageQueue中存在消息,就会将它取出,传递到Hanler.handleMessage() 方法中,每个线程只有一个Looper对象.
异步消息处理的流程:
首先我们在主线程中创建一个Handler对象,并重写它的HandlerMessage方法.当我们需要更改UI时,我们创建一个Message对象,并通过Handler的sendMessage(message) 方法将消息发送出去,之后这条消息会被添加到MessageQueue的队列中等待被处理,这时Looper会一直尝试从MessageQueue中取出消息,最后分发回给handleMessage方法中,由于Handler对象是在主线程中创建的,所以handleMessage也会运行在主线程中。我们就可以安心的进行UI操作了。
三,使用AsyncTask
AsyncTask是一个抽象类,他是由Android封装的一个轻量级异步类(轻量体现在使用方便,代码简洁),它可以在线程池中执行后台任务,然后把执行的进度和最终的结果传递给主线程中并在主线程中更新UI。
AsyncTask的内部封装了两个线程池:
- SerialExecutor :用于任务的排队,让多个需要执行的耗时任务,按顺序排列。
-
THREAD_POOL_EXECUTOR :执行任务
还封装了一个Handler(InternalHandler) 用于从工作线程切换到主线程。
1,AsyncTask的泛型参数
AsyncTask的类声明如下
public abstract class AsyncTask<Params, Progress, Result>
AsyncTask是一个泛型类,其中,三个泛型类型的参数的含义如下:
- Params: 开始异步任务执行时传入的参数类型。
- Progress: 后台任务执行时,如果需要在界面上显示当前的进度,则使用这里指定的泛型作为单位。
- Result: 当任务执行完毕后,如果需要对结果进行返回,则使用这里指定的泛型作为返回值类型。
比如自定义一个AsyncTask就可以写成如下形式:
class DownloadTask extends AsyncTask<Void,Integer,Boolean>
如果AsyncTask确定不需要传递具体参数,那么这三个泛型参数可以用Void代替。
有了这三个参数类型之后,也就控制了这个AsyncTask子类各个阶段返回的类型,如果有不同的业务,我们就需要再另写一个AsyncTask的子类进行处理。
2,AsyncTask的核心方法
-
onPreExecute()
这个方法会在后台任务开始执行之间调用,在主线程中调用,用于界面上一些初始化的操作,比如要显示一个进度条对话框. -
doInBackground(Params…)
这个方法的所有代码都会在子线程中运行,我们应该在这个方法中去处理耗时任务。
任务一旦完成就可以通过return语句来将任务的执行结果进行返回,如果AsyncTask的第三个泛型参数指定的是Void,就可以不返回任务执行结果
注意**在这个方法中不可以对UI进行操作,如果需要更新UI元素,比如说反馈当前任务的执行进度,可以调用publishProgress(Progress…)**方法。 -
onProgrssUpdate(Progress…)
当在后台调用了 publishProgress(Progress) 方法后,这个方法很快会被调用,方法中携带的参数是后台任务中传递过来的 在这个方法中可以对UI进行操作,在主线程中进行 ,利用参数中的数值就可以对界面元素进行相应的更新。 -
onPostExecute(Result)
当doInBackground(Params…) 执行完毕并通过return语句进行返回时,这个方法就会很快被调用,参数中的Result类型与doInBackground方法的返回值有关。 可以利用这个返回的数据进行一些UI操作。 在主线程中运行,比如提醒任务的执行结果,以及关闭掉进度条的对话框。
上面几个方法的调用顺序依次是:
onPreExecute() -> doInBackground(Params…) -> publishProgress(Progress…) -> onProgrssUpdate(Progress…) -> onPostExecute(Result)
如果不需要执行更新进度则为 onPreExecute() -> doInBackground(Params…) -> onPostExecute(Result)
除了上面的方法,AsyncTask还提供了onCancelled() 方法,它同样在主线程中执行,当异步任务取消时,onCancelled() 会被调用,这个时候onPostExecute() 则不会被调用,但是要注意的是,AsyncTask中的cancel()方法并不是真正去取消任务,只是设置这个任务为取消状态 ,我们需要在doInBackground() 判断终止任务。就好比想要终止一个线程,调用interrupt()方法,只是进行标记为中断,需要在线程内部进行标记判断然后中断线程。
package com.example.chen.androidthread;
import android.os.AsyncTask;
import android.widget.Toast;
public class DownloadTask extends AsyncTask <Void,Integer,Boolean>{
@Override
protected void onPreExecute() {
progressDialog.show();
}
@Override
protected Boolean doInBackground(Void... params) {
try {
while (true) {
//这个download()函数时虚构的一个返回下载进度的函数。
int downloadPercent = doDownload();
publishProgress(downloadPercent);
if (downloadPercent >= 100) {
break;
}
}
} catch (Exception e) {
return false;
}
return true;
}
@Override
protected void onProgressUpdate(Integer... values) {
progressDialog.setMessage("当前下载进度:" + values[0] + " %");
}
@Override
protected void onPostExecute(Boolean result) {
progressDialog.dismiss();
if (result) {
Toast.makeText(context, "下载成功", Toast.LENGTH_SHORT).show();
} else {
Toast.makeText(context, "下载失败", Toast.LENGTH_SHORT).show();
}
}
}
如果想要启动这个任务,只需要简单的调用
new DownloadTask().execute()方法。
在AsyncTask中,我们不需要Handler来发送和接收消息,只需要调用一个publishProgress()方法,就能轻松的从子线程切换到UI线程(主线程)了.