原理解析 | Android中HandlerThread原理和使用
HandlerThread是Android開發(fā)中用于啟動(dòng)具有Looper的新線程的線程類,內(nèi)部包含一個(gè)Looper和一個(gè)Handler,可以方便地發(fā)送和處理消息。通過在HandlerThread中處理任務(wù),并通過Handler將結(jié)果發(fā)送回主線程,可以實(shí)現(xiàn)線程間的數(shù)據(jù)傳遞和交互。
原理解析
通過調(diào)用HandlerThread的構(gòu)造函數(shù)并傳入一個(gè)字符串作為線程名創(chuàng)建HandlerThread實(shí)例。
public HandlerThread(String name) {
super(name);
mPriority = Process.THREAD_PRIORITY_DEFAULT;
}
HandlerThread繼承于Thread,本質(zhì)上是一個(gè)線程,其構(gòu)造方法主要是做一些初始化的操作。
我們知道了HandlerThread類其實(shí)就是一個(gè)Thread,start()方法內(nèi)部調(diào)用的肯定是Thread的run方法,我們查看一下其run方法的具體實(shí)現(xiàn)。
@Override
public void run() {
mTid = Process.myTid();
Looper.prepare();
synchronized (this) {
mLooper = Looper.myLooper();
notifyAll();
}
Process.setThreadPriority(mPriority);
onLooperPrepared();
Looper.loop();
mTid = -1;
}
內(nèi)部調(diào)用了Looper.prepate()方法和Loop.loop()方法,熟悉Android異步消息機(jī)制知道,在Android體系中是對(duì)應(yīng)著Looper對(duì)象、MessageQueue對(duì)象,以及Handler對(duì)象。
所以通過run方法,我們可以知道在我們創(chuàng)建的HandlerThread線程中我們創(chuàng)建了該線程的Looper與MessageQueue。
這里需要注意的是其在調(diào)用Looper.loop()方法之前調(diào)用了一個(gè)空的實(shí)現(xiàn)方法onLooperPrepared(),我們可以實(shí)現(xiàn)自己的onLooperPrepared方法做一些Looper的初始化操作;
run方法里面當(dāng)mLooper創(chuàng)建完成后有個(gè)notifyAll(),getLooper()中有個(gè)wait()。因?yàn)閙Looper在一個(gè)線程中執(zhí)行,而我們的Handler是在UI線程初始化的,也就是說(shuō),我們必須等到mLooper創(chuàng)建完成,才能正確的返回getLooper()。wait()``notify()就是為了解決這兩個(gè)線程的同步問題。
我們使用時(shí)需要初始化Handler實(shí)例:
Handler handler = new Handler(handlerThread.getLooper()) {
@Override
public void handleMessage(Message msg) {
// 處理消息
Log.i("HandlerThread", "接收到消息:" + msg.obj.toString());
}
};
Handler的構(gòu)造方法中傳入了HandlerThread的Looper對(duì)象,所以Handler對(duì)象就擁有了HandlerThread線程中Looper對(duì)象的引用。調(diào)用Handler的sendMessage方法發(fā)送消息,在Handler的handleMessge方法中就可以接收到消息。
基本用法
- 創(chuàng)建HandlerThread實(shí)例
通過調(diào)用HandlerThread的構(gòu)造函數(shù)并傳入一個(gè)字符串作為線程名創(chuàng)建HandlerThread實(shí)例。
HandlerThread handlerThread = new HandlerThread("mHandlerThread");
"mHandlerThread"是線程的名字。
- 啟動(dòng)HandlerThread
在創(chuàng)建HandlerThread實(shí)例后,需要調(diào)用start()方法來(lái)啟動(dòng)線程。
handlerThread.start();
- 獲取Handler
HandlerThread啟動(dòng)后,通過調(diào)用getLooper()方法并將其傳遞給Handler的構(gòu)造函數(shù)來(lái)獲取一個(gè)與HandlerThread關(guān)聯(lián)的Handler實(shí)例,用于在HandlerThread中發(fā)送和處理消息。
Handler handler = new Handler(handlerThread.getLooper()) {
@Override
public void handleMessage(Message msg) {
// 處理消息
Log.i("HandlerThread", "接收到消息:" + msg.obj.toString());
}
};
- 發(fā)送消息到HandlerThread
使用上一步中創(chuàng)建的Handler實(shí)例發(fā)送消息到HandlerThread。
// 使用sendMessage()方法發(fā)送消息
Message message = Message.obtain();
message.obj = "111111";
handler.sendMessage(message);
message = Message.obtain();
message.obj = "222222";
handler.sendMessage(message);
// 或者使用post()方法發(fā)送Runnable對(duì)象
handler.post(new Runnable() {
@Override
public void run() {
Log.i("HandlerThread", "執(zhí)行Runnable的run方法");
}
});
- 處理消息
在Handler的handleMessage()方法中處理從主線程或其他線程發(fā)送過來(lái)的消息。
- 停止HandlerThread
通過調(diào)用Handler的quit()或quitSafely()方法來(lái)停止消息循環(huán)。HandlerThread在完成當(dāng)前消息處理后終止。
handler.quit();
// 或者
handler.quitSafely();
- 注意事項(xiàng)
- 在HandlerThread停止后再處理與其相關(guān)的任何資源,避免潛在的內(nèi)存泄漏或其他問題。
- HandlerThread中的任務(wù)是串行執(zhí)行的,如果某個(gè)任務(wù)執(zhí)行時(shí)間過長(zhǎng),可能會(huì)導(dǎo)致后續(xù)任務(wù)被延遲處理。
- 注意線程安全問題,確保在多個(gè)線程之間正確地同步和共享數(shù)據(jù)。