HandlerThread详解
1 HandlerThread基本原理
HandlerThread继承自Thread,它是一种可以使用Handler的Thread。它的实现很简单,就是在run方法中通过Looper.prepare()来创建消息队列,并通过Looper.loop()来开启消息循环。这样,我们就可以直接在HandlerThread中创建Handler了。HandlerThread的run方法如下所示:
public void run() {
mTid = Process.myTid();
Looper.prepare();
synchronized (this) {
mLooper = Looper.myLooper();
notifyAll();
}
Process.setThreadPriority(mPriority);
onLooperPrepared();
Looper.loop();
mTid = -;
}
既然HandlerThread中已经有了消息循环,那么我们就可以在HandlerThread类或其子类中直接创建Handler对象,但是我们要记住一点:如果我们需要创建与该HandlerThread线程相关联的Handler的话,我们要使用Handler(Looper looper)构造方法,这样我们所创建的Handler对象才会与当前线程的消息循环相关联。在HandlerThread中,我们可以通过getLooper()方法获得Looper实例。
从HandlerThread的实现上来看,它和普通Thread有显著不同,普通Thread主要在run方法中执行耗时任务,而HandlerThread在内部创建了消息队列,外界需要通过Handler的消息方式来通知HandlerThread执行一个具体任务。通常,一个普通的Thread线程也可以成为Looper线程,我们只需要为其创建消息队列并开启消息循环即可。看如下实现代码:
class LooperThread extends Thread {
public Handler mHandler; public void run() {
Looper.prepare(); mHandler = new Handler() {
public void handleMessage(Message msg) {
// process incoming messages here
}
}; Looper.loop();
}
}
我们可以根据不同应用场景选择不同的实现方式,不过既然Android已经提供了HandlerThread类,那我们在开发过程中可能会更倾向于使用该类完成耗时操作。
2 示例程序
我们将通过一个简单示例程序来说明HandlerThread的用法。本示例程序中,我们向HandlerThread发送消息,然后HandlerThread返回该消息并显示到TextView上,在这个过程中我们通过sleep来模拟耗时操作。我们将创建一个继承自HandlerThread的类:CustomHandlerThread,
public class CustomHandlerThread extends HandlerThread {
private static final String TAG = "CustomHandlerThread";
private static final int MSG_WHAT = 0x11;
private Handler mResponseHandler;
private Handler mHandler;
private Callback mCallback;
public CustomHandlerThread(Handler responseHandler, Callback callback){
super(TAG);
mHandler = new Handler();
mResponseHandler = responseHandler;
mCallback = callback;
} public void enqueTask(String str, TextView textView){
Log.i(TAG, "receive a str: " + str);
mHandler.obtainMessage(MSG_WHAT, str).sendToTarget();
}
public void prepareHandler(){
mHandler = new Handler(getLooper()){
@Override
public void handleMessage(final Message msg) {
try{
TimeUnit.SECONDS.sleep(2);
final String result = (String)msg.obj;
mResponseHandler.post(new Runnable() {
@Override
public void run() {
mCallback.onResult(result);
}
});
}catch (InterruptedException ie){
ie.printStackTrace();
}
}
};
} public interface Callback{
public void onResult(String result);
}
public void removeMsg(){
mHandler.removeMessages(MSG_WHAT);
} }
我们先看enqueTask方法,该方法很简单,我们仅用它来接收从外部传来的参数(准确的说是消息内容),并且通过当前线程的Handler将消息发送到当前线程消息队列中,对该消息的处理是在prepareHandler()方法中完成的。在prepareHandler方法中,我们创建Handler实例,并且与当前线程的消息队列相关联,这通过Handler(Looper looper)构造方法完成。mResponseHandler.post方法会将Runnable对象添加到主线程的消息队列,该Runnable对象将会在该mResponseHandler所属的线程中执行,由于mResponseHandler是从主线程传过来的(稍后我们会看到具体实现),因此Runnable将会运行在主线程中。run方法中我们通过回调接口来传递结果。下面我们看下MainActivity中的处理:
public class MainActivity extends Activity implements CustomHandlerThread.Callback{
private TextView mTextView; private CustomHandlerThread mCustomHandlerThread;
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_main);
mTextView = (TextView)findViewById(R.id.textView); mCustomHandlerThread = new CustomHandlerThread(new Handler(), this);
mCustomHandlerThread.start();
mCustomHandlerThread.prepareHandler();
for(int i = 0; i < 10; i++){
mCustomHandlerThread.enqueTask("string"+i);
}
} @Override
public void onResult(String result) {
mTextView.setText(result);
} @Override
protected void onDestroy() {
super.onDestroy();
mCustomHandlerThread.removeMsg();
mCustomHandlerThread.quit();
}
}
上面代码很简单,我们创建CustomHandlerThread并传入Handler对象,该Handler对象是在主线程中创建的,因此与主线程消息队列相关联,创建HandlerThread对象后必须要调用start方法,此外,在调用enqueTask之前必须先调用prepareHandler方法,以免导致空指针异常(Handler还没创建?怎么能向消息队列发送消息呢?)。最后要注意的是,当Activity退出时,我们一定要通过quit方法结束HandlerThread的执行。