（Source）HandlerThread

类注释

/*** Handy class for starting a new thread that has a looper. The looper can then be* used to create handler classes. Note that start() must still be called.*/


HandlerThread是拥有Looper的一个线程类&＃xff0c;它继承于Thread&＃xff0c;当它调用 start() 方法后&＃xff0c;通过getLooper()可以传递Looper给Handler&＃xff0c;作为它初始化的参数&＃xff0c;这样就完成了子线程的一个消息循环机制。

构造函数

public HandlerThread(String name, int priority) {super(name);mPriority &＃61; priority;
}


传入线程的名字&＃xff0c;和线程的优先级。

Looper

看到变量里有looper&＃xff0c;

int mPriority;int mTid &＃61; -1;Looper mLooper;


再查到继承于Thread的run()方法&＃xff1a;

&＃64;Override
public void run() {mTid &＃61; Process.myTid();Looper.prepare();synchronized (this) {mLooper &＃61; Looper.myLooper();notifyAll();}Process.setThreadPriority(mPriority);onLooperPrepared();Looper.loop();mTid &＃61; -1;
}


先记录线程的TID&＃xff0c;然后Looper.prepare&＃xff0c;初始化好Looper&＃xff0c;Looper内部初始化好MessageQueue&＃xff0c;然后 notifyAll()&＃xff0c;唤醒所有等待中的线程&＃xff1f;啥&＃xff0c;为什么呢&＃xff1f;先搁置&＃xff0c;看下去&＃xff0c;接着设置线程优先级&＃xff0c;然后&＃xff0c;调用一个方法&＃xff1a;onLooperPrepared() :

/*** Call back method that can be explicitly overridden if needed to execute some* setup before Looper loops.*/
protected void onLooperPrepared() {
}


从注释看到&＃xff0c;这个方法通常用于重写&＃xff0c;在looper开始消息循环前进行一些初始化操作。回到上面的代码&＃xff0c;最后就是开启 looper.loop() 开启消息循环。

getLooper()

从类注释看到&＃xff0c;HandlerThread 是包含了Looper的子线程&＃xff0c;不需要操作Looper就可以使用Handler机制&＃xff0c;我们看到它的 getLooper() 方法&＃xff1a;

public Looper getLooper() {if (!isAlive()) {return null;}// If the thread has been started, wait until the looper has been created.synchronized (this) {while (isAlive() && mLooper &＃61;&＃61; null) {try {wait();} catch (InterruptedException e) {}}}return mLooper;
}


如果线程因为某些原因&＃xff0c;isAlive 返回 false&＃xff0c;则返回 null 的looper。如果线程已经 start了&＃xff0c;但是呢还未初始化好 looper&＃xff0c;那么会一直阻塞&＃xff1a;while (isAlive() && mLooper &＃61;&＃61; null)&＃xff0c;细心的同学看到里面&＃xff0c;有 wait() &＃xff0c;休眠线程&＃xff0c;那么在什么时候被唤醒呢&＃xff1f;噢噢&＃xff0c;恍然大悟&＃xff0c;就是上面的 run() 方法里面的 notifyAll() 啊&＃xff0c;原来它唤醒的线程就是在这里&＃xff0c;然后就接着返回正确的 looper啊&＃xff0c;哈哈&＃xff0c;SogaSoga。

quit

quit结束Looper的消息循环&＃xff0c;有两个方法&＃xff0c;safe quit 和 not safe quit&＃xff0c;其都是调用 looper 的对应方法&＃xff1a;

public boolean quit() {Looper looper &＃61; getLooper();if (looper !&＃61; null) {looper.quit();return true;}return false;}


public boolean quitSafely() {Looper looper &＃61; getLooper();if (looper !&＃61; null) {looper.quitSafely();return true;}return false;
}


那么这两个方法有什么区别呢&＃xff1f;我们还是看看 &＃xff08;Source&＃xff09;MessageQueue 源码里面&＃xff0c;这里举个例子吧&＃xff1a;

public class HandlerThreadActivity extends AppCompatActivity {private HandlerThread handlerThread;private String TAG &＃61; "HandlerThreadTest";private Handler handler;&＃64;Overrideprotected void onCreate(Bundle savedInstanceState) {super.onCreate(savedInstanceState);setContentView(R.layout.activity_handler_thread);Log.i(TAG,"onCreate");handlerThread &＃61; new HandlerThread(TAG) {&＃64;Overrideprotected void onLooperPrepared() {super.onLooperPrepared();Log.i(TAG,"onLooperPrepared, "&＃43;Thread.currentThread().getName());}};handlerThread.start();handler &＃61; new Handler(handlerThread.getLooper()) {&＃64;Overridepublic void handleMessage(Message msg) {switch (msg.what) {case 0x01:Log.i(TAG,"handleMessage, 0x01, start");try {Thread.sleep(10*1000);} catch (InterruptedException e) {e.printStackTrace();}Log.i(TAG,"handleMessage, 0x01, done");break;case 0x02:Log.i(TAG,"handleMessage, 0x02, done");break;}}};findViewById(R.id.btn_1).setOnClickListener(v -> {handler.sendEmptyMessage(0x01);});findViewById(R.id.btn_2).setOnClickListener(v -> {handler.sendEmptyMessage(0x02);});}&＃64;Overrideprotected void onDestroy() {super.onDestroy();Log.i(TAG,"onDestroy");//handlerThread.quit();handlerThread.quitSafely();}
}


很简单的页面&＃xff0c;点击按钮分别发送不同的消息&＃xff0c;一条是阻塞线程的消息。在 onDestory() 中分别使用 quit() quitSafely() 观察log&＃xff1a;

场景1&＃xff0c;点击两次btn1&＃xff0c;发送两个Message消息A1,A2&＃xff0c;然后立即点击 btn2&＃xff0c;发送一个Message消息B&＃xff0c;立即退出这个activity

• quit()&＃xff1a;

I/HandlerThreadTest: onCreate
I/HandlerThreadTest: onLooperPrepared, HandlerThreadTest
I/HandlerThreadTest: handleMessage, 0x01, start
I/HandlerThreadTest: onDestroy
I/HandlerThreadTest: handleMessage, 0x01, done


结合源码解析&＃xff0c;quit() 直接退出&＃xff0c;并remove所有在等待处理的消息&＃xff0c;就是说&＃xff0c;后面发送的A2和B被直接扔掉&＃xff0c;而正在处理的 A1 就等待处理完成。

• quitSafe():

I/HandlerThreadTest: onCreate
I/HandlerThreadTest: onLooperPrepared, HandlerThreadTest
I/HandlerThreadTest: handleMessage, 0x01, start
I/HandlerThreadTest: onDestroy
I/HandlerThreadTest: handleMessage, 0x01, done
I/HandlerThreadTest: handleMessage, 0x01, start
I/HandlerThreadTest: handleMessage, 0x01, done
I/HandlerThreadTest: handleMessage, 0x02, done


有点不同&＃xff0c;MessageQueue 的消息按照处理的时间 time 做了一个从小到大的排序&＃xff0c;调用quitSafe的时刻假设为 currentTime&＃xff0c;那么从MessageQueue的队列头开始寻找&＃xff0c;直到有一个message.when>currentTime&＃xff0c;那么就从这个message开始remove。也就是说&＃xff0c;quitSafe时刻&＃xff0c;的未来处理的消息全部会被remove调&＃xff0c;而之前的消息会一直等待处理。我们来验证一下&＃xff1a;

场景2&＃xff1a;btn2的消息delay 10 秒&＃xff0c;同样地点击两次btn1&＃xff0c;发送两个Message消息A1,A2&＃xff0c;然后立即点击 btn2&＃xff0c;发送一个Message消息B&＃xff0c;立即退出这个activity

findViewById(R.id.btn_2).setOnClickListener(v -> {handler.sendEmptyMessageDelayed(0x02,10*1000);
});


• quit() :

I/HandlerThreadTest: onCreate
I/HandlerThreadTest: onLooperPrepared, HandlerThreadTest
I/HandlerThreadTest: handleMessage, 0x01, start
I/HandlerThreadTest: onDestroy
I/HandlerThreadTest: handleMessage, 0x01, done


跟场景1一样的log&＃xff0c;quit() 这么残暴地直接remove所有的消息。

• quitSafe()&＃xff1a;

I/HandlerThreadTest: onCreate
I/HandlerThreadTest: onLooperPrepared, HandlerThreadTest
I/HandlerThreadTest: handleMessage, 0x01, start
I/HandlerThreadTest: onDestroy
I/HandlerThreadTest: handleMessage, 0x01, done
I/HandlerThreadTest: handleMessage, 0x01, start
I/HandlerThreadTest: handleMessage, 0x01, done


和上面解释符合。btn2发送的消息&＃xff0c;在quitSafe的时刻相对来说是未来的事件&＃xff0c;因而只有它被remove。

总结

• HandlerThread 继承于 Thread&＃xff0c;拥有 Looper&＃xff0c;用于构造基于子线程的 handler 消息循环。
• HandlerThread 的实例要 调用 start() 后才能 getLooper()
• 清楚知道 quit() 和 quitSafe() 的区别
• HandlerThread.getLooper() 有可能会阻塞线程