Looper
在介绍Handler之前,我们先来看下Looper,Android消息循环中一个非常重要的类。
Looper主要是为了创建一个线程的消息循环,在Android中每个线程默认是没有消息循环的,我们得手动为某个线程创建一个Looper,不管是UI线程还是工作线程,我们都得手动创建。
我们可以调用Looper的prepare方法来为当前线程创建一个Looper,然后调用loop开始进行循环。
下面来分析一下Looper的源码
Looper中两个核心方法,prepare&loop
prepare,Looper的初始化
public static void prepare() {
prepare(true);
}
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));
}
从代码中可以看出来,先通过ThreadLocal的get方法来获取当前线程是否已经有了Looper,如果已经有了则抛出我们熟悉的异常,Only one Looper may be created per thread,也就是每个线程只能有一个Looper,面试经常问哈。如果当前线程还没有Looper,则创建一个Looper并且通过ThreadLocal设置给当前线程。
咱么接着看Looper的构造方法
private Looper(boolean quitAllowed) {
mQueue = new MessageQueue(quitAllowed);
mThread = Thread.currentThread();
}
很简单啊,就是创建了一个消息队列MessageQueue。
在Looper中还有另外一个创建Looper的方法,那就是prepareMainLooper,
public static void prepareMainLooper() {
prepare(false);
synchronized (Looper.class) {
if (sMainLooper != null) {
throw new IllegalStateException("The main Looper has already been prepared.");
}
sMainLooper = myLooper();
}
}
我们平时开发过程中一般不会使用这个方法,这个方法其实是在ActivityThread.java中的main函数中调用的,这个main函数在进程启动时会被调用。
public static void main(String[] args) {
Looper.prepareMainLooper();
Looper.loop();
}
也就是在主线程中已经创建了一个Looper,这就是我们平时在主线程使用Handler时不用自己创建Looper的原因。
loop,开始消息循环
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;
...
for (;;) {
Message msg = queue.next(); // might block
if (msg == null) {
// No message indicates that the message queue is quitting.
return;
}
...
try {
msg.target.dispatchMessage(msg);
} finally {
...
}
...
msg.recycleUnchecked();
}
}
我简化了一下代码,可以看出来loop主要是从队列中取出Message,然后调用Message.targe的dispatchMessage来分发消息,如果队列中没有Message,则阻塞着。关于这个Message.target是什么,后面Handler分析中会说到哈。
这里思考一个问题,就是我们刚刚说到在ActivityThread中调用了主线程的Looper的loop函数。那么,我们发现在loop中有个for循环,并且是死循环,那么这个不会阻塞主线程吗?
关于这个问题,可以参考一下https://www.zhihu.com/question/34652589/answer/90344494
Handler
我们来看下Handler的简单使用
public class DemoActivty extends Activity {
class MyHandler extends Handler{
@Override
public void handleMessage(Message msg) {
super.handleMessage(msg);
Log.d(TAG,msg.obj.toString());
}
}
@Override
protected void onCreate(@Nullable Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
MyHandler handler = new MyHandler();
new Thread(){
@Override
public void run() {
super.run();
Message message = new Message();
message.obj = "luping";
handler.sendMessage(message);
}
}.start();
}
}
很简单的一个例子,就是在子线程调用handler.sendMessage来将Message传递给主线程。
首先看一下Handler的构造方法
public Handler(Callback callback, boolean async) {
mLooper = Looper.myLooper();
if (mLooper == null) {
throw new RuntimeException(
"Can't create handler inside thread that has not called Looper.prepare()");
}
mQueue = mLooper.mQueue;
mCallback = callback;
}
从上面代码可以看出来,主要是获取创建Handler的线程的Looper以及Looper中的Queue,如果没有获取到Looper就会抛出异常让使用Looper.prepare来创建Looper。
而我们在平时开发过程中,直接在主线程创建handler为啥没有抛出异常呢?这个在前面已经说过了,就是在ActivityThread中已经帮我们创建了主线程的Looper,所以才不会抛出异常。
接着再看下Handler的sendMessage方法
public boolean sendMessageAtTime(Message msg, long uptimeMillis) {
MessageQueue queue = mQueue;
if (queue == null) {
RuntimeException e = new RuntimeException(
this + " sendMessageAtTime() called with no mQueue");
Log.w("Looper", e.getMessage(), e);
return false;
}
return enqueueMessage(queue, msg, uptimeMillis);
}
private boolean enqueueMessage(MessageQueue queue, Message msg, long uptimeMillis) {
msg.target = this;
if (mAsynchronous) {
msg.setAsynchronous(true);
}
return queue.enqueueMessage(msg, uptimeMillis);
}
上面方法,主要是将Message加入到Looper中的MessageQueue。需要留意一下,msg.target=this,这里的this就是Handler了。
我们在上面介绍Looper的loop方法中说到,一旦MessageQueue中有消息加入,Looper就会调msg.target.dispatchMessage(msg);来分发消息,也就是调用Handler的dispatchMessage方法来处理消息。
再来看下dispatchMessage方法
public void dispatchMessage(Message msg) {
if (msg.callback != null) {
handleCallback(msg);
} else {
if (mCallback != null) {
if (mCallback.handleMessage(msg)) {
return;
}
}
handleMessage(msg);
}
}
就是调用Handler的handleMessage来处理消息,上面的例子中Handler是在主线程创建的,也就实现了将Message从子线程传递到主线程了。
网友评论