前言
Handler是安卓開發(fā)中我們常用的,主要用于線程之間的通訊,本文通過handler的幾個常用方法來分析下具體的源碼實(shí)現(xiàn)
常規(guī)操作
//創(chuàng)建消息
Message msg = Message.obtain();
msg.what=101;
msg.obj="send message";
//發(fā)送消息
mHandler.sendMessage(msg);
//接受消息
private Handler mHandler = new Handler(){
@Override
public void handleMessage(Message msg) {
LogUtils.LogE(msg.toString());
}
};
這種寫法是我們用的最多的寫法,下面來具體介紹它的實(shí)現(xiàn)原理
主要方法
- 無論是sendMessage或sendMessageDelayed，sendEmptyMessageDelayed最終調(diào)用的方法都是sendMessageAtTime方法,sendMessageAtTime調(diào)用的是MessageQueue中的enqueueMessage方法,下面是核心代碼:
//MessageQueue中:
boolean enqueueMessage(Message msg, long when) {
//省略片段代碼
msg.markInUse();
msg.when = when;
Message p = mMessages;
boolean needWake;
if (p == null || when == 0 || when < p.when) {
msg.next = p;
mMessages = msg;
needWake = mBlocked;
} else {
needWake = mBlocked && p.target == null && msg.isAsynchronous();
Message prev;
for (;;) {
prev = p;
p = p.next;
if (p == null || when < p.when) {
break;
}
if (needWake && p.isAsynchronous()) {
needWake = false;
}
}
msg.next = p; // invariant: p == prev.next
prev.next = msg;
}
if (needWake) {
nativeWake(mPtr);
}
}
return true;
}
- MessageQueue類似于鏈表結(jié)構(gòu)
- if (p == null || when == 0 || when < p.when):p為等待執(zhí)行的message隊(duì)列when為我們傳入delay的時間值如果mMessages對象為空，或者when為0也就是立刻執(zhí)行，或者新消息的when時間比mMessages隊(duì)列的when時間還要早
- 符合以上一個條件就把新的msg插到mMessages的前面 并把next指向它,也就是msg會插進(jìn)隊(duì)列的最前面，等待loop的輪詢
- 如果上述所有條件都不符合就進(jìn)入else
- else中是一個死循環(huán),when是指新消息的執(zhí)行時間,p.when是指隊(duì)列中message消息的執(zhí)行時間
- 如果新消息的執(zhí)行時間比隊(duì)列里面的消息執(zhí)行時間早就跳出循環(huán),執(zhí)行 msg.next = p;prev.next = msg,也就是插入到隊(duì)列前面先執(zhí)行它
Handler怎么與looper還有MessageQueue關(guān)聯(lián)的呢?
在ActivityThread.main() 方法中有如下代碼：
public static void main(String[] args) {
//省略若干代碼
Looper.prepareMainLooper();
ActivityThread thread = new ActivityThread();
thread.attach(false);
if (sMainThreadHandler == null) {
sMainThreadHandler = thread.getHandler();
}
Looper.loop();
}
- 原來在 ActivityThread 里 調(diào)用了 Looper.prepareMainLooper() 方法創(chuàng)建了 主線程的 Looper ,并且調(diào)用了 loop() 方法，所以我們就可以直接使用 Handler 了
private static void prepare(boolean quitAllowed) {
if (sThreadLocal.get() != null) {
throw new RuntimeException("Only one Looper may be created per thread");
}
sThreadLocal.set(new Looper(quitAllowed));
}
- 這里是looper與當(dāng)前線程進(jìn)行綁定，prepare方法不能調(diào)用二次,這也代表了一個線程只能有一個looper
private Looper(boolean quitAllowed) {
mQueue = new MessageQueue(quitAllowed);
mThread = Thread.currentThread();
}
- 這里MessageQueue是與當(dāng)前的looper關(guān)聯(lián)
最后調(diào)用loop方法不斷去輪詢MessageQueue中的消息
public static void loop() {
final Looper me = myLooper();
if (me == null) {
throw new RuntimeException("No Looper; Looper.prepare() wasn't called on this thread.");
}
final MessageQueue queue = me.mQueue;
Binder.clearCallingIdentity();
final long ident = Binder.clearCallingIdentity();
for (;;) {
Message msg = queue.next(); // might block
if (msg == null) {
// No message indicates that the message queue is quitting.
return;
}
final long start = (slowDispatchThresholdMs == 0) ? 0 : SystemClock.uptimeMillis();
final long end;
try {
msg.target.dispatchMessage(msg);
end = (slowDispatchThresholdMs == 0) ? 0 : SystemClock.uptimeMillis();
} finally {
if (traceTag != 0) {
Trace.traceEnd(traceTag);
}
}
if (slowDispatchThresholdMs > 0) {
final long time = end - start;
}
final long newIdent = Binder.clearCallingIdentity();
msg.recycleUnchecked();
}
}
- me為 null就拋出異常,也就是必須先調(diào)用prepare方法后才能調(diào)用loop方法
- 不管什么Handler在什么線程發(fā)消息,接受消息的線程都是Looper.loop()所調(diào)用的線程
- 拿到looper中的隊(duì)列進(jìn)入死循環(huán)
- 不斷取出消息,如果沒有消息就return
- 最后調(diào)用msg.target.dispatchMessage也就是Handler來分發(fā)消息
public void dispatchMessage(Message msg) {
if (msg.callback != null) {
handleCallback(msg);
} else {
if (mCallback != null) {
if (mCallback.handleMessage(msg)) {
return;
}
}
handleMessage(msg);
}
}
- msg 沒有 callback 的話，那么將會判斷 mCallback 是否為空，這個 mCallback 就是構(gòu)造方法種傳遞的那個 Callback,優(yōu)先執(zhí)行
- 如果 mCallback為空,那么就調(diào)用 Handler 的 handleMessage(msg) 方法，否則就調(diào)用 mCallback.handleMessage(msg) 方法，然后根據(jù) mCallback.handleMessage(msg)的返回值判斷是否攔截消息，如果攔截(返回 true)
- mCallback.handleMessage(msg)返回true,Handler的handleMessage將不會調(diào)用
問題&解答
主線程為什么不用創(chuàng)建Looper?
- 因?yàn)樵贏ctivityThread.main()方法中已經(jīng)把Looper給我們創(chuàng)建好了并且調(diào)用了loop方法
- 所有我們在主線程使用handler不用調(diào)用Looper,handleMessage回調(diào)在主線程(Looper.loop()方法在主線程)
子線程怎么使用Handler?
new Thread(){
@Override
public void run() {
Looper.prepare();
Handler handler = new Handler(){
@Override
public void handleMessage(Message msg) { }
};
handler.sendEmptyMessage(11);
Looper.loop();
}
}.start();
- 必須調(diào)用Looper.prepare()再調(diào)用 Looper.loop()方法輪詢消息,否則會拋出 RuntimeException("No Looper; Looper.prepare() wasn't called on this thread.")
handler#postRunnable方法是在新的線程嗎?
private static Message getPostMessage(Runnable r) {
Message m = Message.obtain();
m.callback = r;
return m;
}
private static void handleCallback(Message message) {
message.callback.run();
}
- post方法最終調(diào)用的都是這個方法,把Runnable賦值給Message.callback
- 最終走到handleMessage方法中調(diào)用handleCallback方法即調(diào)用post方法里傳遞的 Runnable 對象的run()方法
- 總結(jié):只是一個回調(diào)方法與線程無關(guān)
handler內(nèi)存泄漏?
8A0FV6H37~OR4_$R2~DCUEP.png
- 這是我們使用handler常見的警告提醒,原因是內(nèi)部類持有外部類引用，從而外部類銷毀時不能被回收而導(dǎo)致內(nèi)存泄漏
解決方法
- 在onpause方法中removeCallbacksAndMessages(null),移除消息
- 使用static加弱引用的方法
private static class MyHandler extends Handler {
private WeakReference<StudyActivity> mReference;
public MyHandler(StudyActivity activity) {
mReference = new WeakReference<StudyActivity>(activity);
}
@Override
public void handleMessage(Message msg) {
StudyActivity activity = mReference.get();
if (activity != null) {
LogUtils.LogE(msg.what);
}
}
}
總結(jié)
- Handler 的創(chuàng)建需要先調(diào)用 Looper.prepare() ，然后再手動調(diào)用 loop()方法開啟循環(huán)
- App 啟動時會在ActivityThread.main()方法中創(chuàng)建主線程的 Looper ,并開啟循環(huán)，所以主線程使用 Handler 不用調(diào)用looper
- Callback.handleMessage() 的優(yōu)先級比 Handler.handleMessage()要高
- Handler.post(Runnable)傳遞的 Runnale 對象并不會在新的線程執(zhí)行
- 可以通過removeCallbacksAndMessages(null)或者靜態(tài)類加弱引用的方式防止內(nèi)存泄漏
- handlermessage回調(diào)是在Looper.loop()所在線程
