下了7.0系统的源码,打算要赶在过阴历年之前,看一些东西!不能再这么颓废下去了!
早上又复习了Handler的运行流程,看了源码后,感觉和几年前看的时候真是大不相同!
OK,不皮了,进入正题!
嗯,从ActivityThread开始吧!因为它是隐藏的,在你的IDE中是看不到的!所以在你解压系统源码后的android-7.1.0_r1\frameworks\base\core\java\android\app这个目录下,你可以找道这个文件!当然,如果你觉得系统源码有点大,自己的网速有很烂下载不方便,你可以在这个网址在线看
在ActivityThread这个文件的末尾,你会看到一个main函数,这个就是程序的入口了。
OK,功力有限,其它的我们先不考虑,我们先来看我们能看的懂的。
看到 Looper.prepareMainLooper();//.......Looper.loop();应该知道为啥我们可以在主线程中直接使用Handler了吧!哈哈..
我们看看Looper.prepareMainLooper();做了哪些操作。
这几行英文注释很简单,大意呢就是,android系统为创建了一个当前线程的looper,作为我们的application的主looper。看到 我们熟悉的prepare(false);我们还是点进去瞅瞅
看仔细点,这是两个方法,一个带参数的,一个不带参数的,同样的都是为我们Handler提供一个Looper的,带参数的跟不带参数有什么区别呢?嗯,还是看注释,当你的参数是true的时候,我们自己创建的looper会自动调用quit(),进行注销操作,回到上面的Looper.prepareMainLooper(),它的方法体中传的false,也就是说,我们系统在创建主线程的Looper是不会自动销毁的,为什么要销毁呢?下面我们看loop()方法体的时候,你就明白了!
我们接着看prepare(boolean quitAllowed)中的代码,sThreadLocal.get(),sThreadLocal是啥玩意,跟上去看看
static final ThreadLocal<Looper> sThreadLocal = new ThreadLocal<Looper>();
直接实例化了,还是静态的!点进去,只有这么简单的一行描述:
[图片上传失败...(image-afd390-1514970145505)]
创建一个线程局部变量!!emmm,不太明白,那我们先跳过看它怎么给参数的:
sThreadLocal.set(new Looper(quitAllowed));
嗯,大概明白了,sThreadLocal维护的是一个保存当前运行线程变量信息的HashMap!
它的get方法如下:
我们再捋一遍哈!当执行Loop的 prepare()方法的时候,会判断当前的线程信息,也就是为啥会抛出一个线程只允许创建一次prepare()的异常;
接着,如果当前线程还没prepare();,我们也就创建出了Looper的实例,并将其塞入ThreadLocal
实例化这步中,我们就为我们当前的线程创建出了MessageQueue(消息队列),并拿到当前线程的各个信息!
OK!至此,我们总算是搞清楚了Looper的实例化,是在prepare(),中完成,并且,并且,并且(重要的事情说三遍!我们也创建出了当前线程的一个消息循环器。
当前线程的消息循环器创建好了,但是我们还没有启动它!那怎么启动呢?
终于到Looper.loop();他就是启动轮询器的执行方法体了!
/**
* Run the message queue in this thread. Be sure to call
* {@link #quit()} to end the 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;
// Make sure the identity of this thread is that of the local process,
// and keep track of what that identity token actually is.
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;
}
// This must be in a local variable, in case a UI event sets the logger
final Printer logging = me.mLogging;
if (logging != null) {
logging.println(">>>>> Dispatching to " + msg.target + " " +
msg.callback + ": " + msg.what);
}
final long traceTag = me.mTraceTag;
if (traceTag != 0 && Trace.isTagEnabled(traceTag)) {
Trace.traceBegin(traceTag, msg.target.getTraceName(msg));
}
try {
msg.target.dispatchMessage(msg);
} finally {
if (traceTag != 0) {
Trace.traceEnd(traceTag);
}
}
if (logging != null) {
logging.println("<<<<< Finished to " + msg.target + " " + msg.callback);
}
// Make sure that during the course of dispatching the
// identity of the thread wasn't corrupted.
final long newIdent = Binder.clearCallingIdentity();
if (ident != newIdent) {
Log.wtf(TAG, "Thread identity changed from 0x"
+ Long.toHexString(ident) + " to 0x"
+ Long.toHexString(newIdent) + " while dispatching to "
+ msg.target.getClass().getName() + " "
+ msg.callback + " what=" + msg.what);
}
msg.recycleUnchecked();
}
}
我们一行一行来吧!
根据下面抛出的异常,我们应该可以知道些什么!跳进去:
阿西吧,这不就是prepare()的时候塞进去的那个Looper嘛!
final MessageQueue queue = me.mQueue;
这行不就是,Looper实例化创建的那个MessageQueue嘛
一个不可打断的死for循环!无限循环的消息队列是不是用Looper.loop();搞定了!
并且,我们是不是看到一个熟悉的方法调用?哈哈!
msg.target.dispatchMessage(msg);
是Handler的方法体吧!!!
OK,到这里,当前线程无限循环的消息队列是创建成功了!
那么问题又来了?Handler是怎么把消息存到当前线程无限循环的消息队列呢?
默认Handler实例化
this方法体:
看到执行了!!!
mLooper = Looper.myLooper();//获取当前线程Looper
mQueue = mLooper.mQueue;//获取当前线程的消息队列
OK,初始化完成,拿到当前线程的Looper了,拿到了当前线程Looper关联的消息队列mQueue.
再接着,我们发送一个最简单的消息进行处理!
嗯,接着走!
我们看一下这两行代码发生了什么!
Message msg = Message.obtain();
msg.what = what;
给的注释说我们 从公共池中返回一个新的消息实例,让我们避免在许多情况下分配新对象。
解释一下吧!上面多截出来的几个变量很重要,sPool是一个全局的Message的索引,这也是就注释的第一句话的意思,当前对象中如果存在Message对象,我们不需要创建新的实例对象,然后会将当前Message的各个信息补充完整,它的next也是一个Message对象,我们会将当前存在的Message对象生成一个新的Message节点,就酱!那如果没有的话,则返回一个新的new Message(),我们面试常问到的Handler绑定,也就是target的赋值,还没到,大家不要急!
回到Handler,我们接着往下走!
没有什么有用的信息,接着往下走!
我们初始化Handler的时候mQueue,被赋给别人了!
接着走!
来了,此时将Handler附在Message上了!!!!
接着看return queue.enqueueMessage(msg, uptimeMillis);
从字面理解,是将Message和执行的时间点存入了MessageQueue中!我们也跟进去看看!
boolean enqueueMessage(Message msg, long when) {
if (msg.target == null) {
throw new IllegalArgumentException("Message must have a target.");
}
if (msg.isInUse()) {
throw new IllegalStateException(msg + " This message is already in use.");
}
synchronized (this) {
if (mQuitting) {
IllegalStateException e = new IllegalStateException(
msg.target + " sending message to a Handler on a dead thread");
Log.w(TAG, e.getMessage(), e);
msg.recycle();
return false;
}
msg.markInUse();
msg.when = when;
Message p = mMessages;
boolean needWake;
if (p == null || when == 0 || when < p.when) {
// New head, wake up the event queue if blocked.
msg.next = p;
mMessages = msg;
needWake = mBlocked;
} else {
// Inserted within the middle of the queue. Usually we don't have to wake
// up the event queue unless there is a barrier at the head of the queue
// and the message is the earliest asynchronous message in the queue.
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;
}
// We can assume mPtr != 0 because mQuitting is false.
if (needWake) {
nativeWake(mPtr);
}
}
return true;
}
这段代码就是将Message插入MessageQueue中,主要的几行代码,我标出来了!哈哈
其实没什么可说的这个方法,主要是按照when(执行时间点)来插入队列中!当没有消息可插入的时候,就会跳出这个循环!
总结:
实例化Handler(拿到当前线程的Looper,MessageQueue),发送消息(将生成的携带Handler标记的Message插入MessageQueue),完成了消息的生成存储流程!之后的Looper.loop();方法就将开无限循环处理消息了!
这篇写的有些简陋,感觉主要是整个流程框架有点庞大复杂,整体的把握还是有些不足!这是我这边的复习总结!个人感觉吧,大家还是自己看看源码比较好!哈哈!话说回来,面试的时候这个问道的概率很大很大!掌握其中的各个关键点和整体的架构把握很重要!
OK,据扯到这了!
每天进步一点点,时间会让你成为巨人!加油!