标签:android style blog io ar color 使用 sp for
我们都知道,耗时操作不应该在主线程中执行,比如从服务器获取数据然后更新界面。但是,界面更新却只能在主线程中执行。这时,一般都会开启线程获取服务器的数据,然后通过Handler将数据发送到主线程,在主线程中进行界面更新。一般来说我们的做法都是这样:
1 new Thread(new Runnable() { 2 @Override 3 public void run() { 4 Looper.prepare(); 5 mHandler = new MyHandler(); 6 Message msg = new Message(); 7 msg.obj = "Text"; 8 mHandler.sendMessage(msg); 9 Looper.loop(); 10 } 11 }).start();
MyHandler继承Handler,并且复写了handleMessage(Message msg)方法,代码如下:
1 class MyHandler extends Handler{ 2 @Override 3 public void handleMessage(Message msg) { 4 String text = (String)msg.obj; 5 mTextView.setText(text); 6 } 7 }
在handleMessage方法中,就可以处理从线程中发送过来的数据并更新控件(mTextView)了。知道怎么用,有个蛋用啊,得知道其原理啊(衰!!!)。那就来看源码吧。
1)来看看Looper.prepare做了什么?
prepare()方法中调用了其重载方法,并传入了参数true。
1 private static void prepare(boolean quitAllowed) { 2 if (sThreadLocal.get() != null) { 3 throw new RuntimeException("Only one Looper may be created per thread"); 4 } 5 sThreadLocal.set(new Looper(quitAllowed)); 6 }
sThreadLocal是ThreadLoacl是对象,关于ThreadLocal,只需要知道ThreadLocal为每个使用该变量的线程提供独立的变量副本,所以每一个线程都可以独立地改变自己的副本,而不会影响其它线程所对应的副本。这里的sThreadLocal保存的是Looper对象。一个线程中最多只能有一个Looper,并且只能在prepare方法中创建。所以一个线程中最多只能调用一次Looper.prepare,否则就会抛出RuntimeException("Only one Looper may be created per thread")。
sThreadLocal.set(new Looper(quitAllowed)); new出了一个Looper并且将其添加进sThreadLocal中。
2)Looper的构造方法中做了什么?
1 private Looper(boolean quitAllowed) { 2 mQueue = new MessageQueue(quitAllowed); 3 mRun = true; 4 mThread = Thread.currentThread(); 5 }
MessageQueue是一个先进先出的消息队列,我们通过handler发送的消息就是由其。
3)发送消息
现在MessageQueue已经有了,就等消息发送过来了。通过handler.sendMessage方法发送的消息,最终都会进入到下面这个方法中:
1 public boolean sendMessageAtTime(Message msg, long uptimeMillis) { 2 MessageQueue queue = mQueue; 3 if (queue == null) { 4 RuntimeException e = new RuntimeException( 5 this + " sendMessageAtTime() called with no mQueue"); 6 Log.w("Looper", e.getMessage(), e); 7 return false; 8 } 9 return enqueueMessage(queue, msg, uptimeMillis); 10 }
mQueue是在构造方法中通过获得当前线程的Looper来获取的。enqueueMessage,最终其实现是调用MessageQueue.enqueueMessage来实现,就是将消息添加到队列中,来是怎么实现的。
1 final boolean enqueueMessage(Message msg, long when) { 2 if (msg.isInUse()) { 3 throw new AndroidRuntimeException(msg + " This message is already in use."); 4 } 5 if (msg.target == null) { 6 throw new AndroidRuntimeException("Message must have a target."); 7 } 8 9 boolean needWake; 10 synchronized (this) { 11 if (mQuiting) { 12 RuntimeException e = new RuntimeException( 13 msg.target + " sending message to a Handler on a dead thread"); 14 Log.w("MessageQueue", e.getMessage(), e); 15 return false; 16 } 17 18 msg.when = when; 19 Message p = mMessages; 20 if (p == null || when == 0 || when < p.when) { 21 // New head, wake up the event queue if blocked. 22 msg.next = p; 23 mMessages = msg; 24 needWake = mBlocked; 25 } else { 26 // Inserted within the middle of the queue. Usually we don‘t have to wake 27 // up the event queue unless there is a barrier at the head of the queue 28 // and the message is the earliest asynchronous message in the queue. 29 needWake = mBlocked && p.target == null && msg.isAsynchronous(); 30 Message prev; 31 for (;;) { 32 prev = p; 33 p = p.next; 34 if (p == null || when < p.when) { 35 break; 36 } 37 if (needWake && p.isAsynchronous()) { 38 needWake = false; 39 } 40 } 41 msg.next = p; // invariant: p == prev.next 42 prev.next = msg; 43 } 44 } 45 if (needWake) { 46 nativeWake(mPtr); 47 } 48 return true; 49 }
方法有点长,挑重点看。消息的添加,其实就是在if else中这一段代码中实现的。Message,是琏表。知道了这一点,其实上面的重点代码也就不难理解了。当前队列为空,或者when(从开机到现在的毫秒数,加上delay)为0,或者当前的消息的时间比前一个消息的时间小,都会被判断为当前队列中没有消息。代码会进入到if片段。当队列中有消息,进入到else,通过琏表添加元素的方式,把消息添加到队列中。
OK,发送消息,把消息添加进队列的都已经完成了,那消息是如何从队列中取出来,并交给handler处理的呢?
4)Looper.loop()
从队列中取出消息,并交给handler处理,都在这里面了。
1 /** 2 * Run the message queue in this thread. Be sure to call 3 * {@link #quit()} to end the loop. 4 */ 5 public static void loop() { 6 final Looper me = myLooper(); 7 if (me == null) { 8 throw new RuntimeException("No Looper; Looper.prepare() wasn‘t called on this thread."); 9 } 10 final MessageQueue queue = me.mQueue; 11 12 // Make sure the identity of this thread is that of the local process, 13 // and keep track of what that identity token actually is. 14 Binder.clearCallingIdentity(); 15 final long ident = Binder.clearCallingIdentity(); 16 17 for (;;) { 18 Message msg = queue.next(); // might block 19 if (msg == null) { 20 // No message indicates that the message queue is quitting. 21 return; 22 } 23 24 // This must be in a local variable, in case a UI event sets the logger 25 Printer logging = me.mLogging; 26 if (logging != null) { 27 logging.println(">>>>> Dispatching to " + msg.target + " " + 28 msg.callback + ": " + msg.what); 29 } 30 31 msg.target.dispatchMessage(msg); 32 33 if (logging != null) { 34 logging.println("<<<<< Finished to " + msg.target + " " + msg.callback);
额,也相当长,同样,看重点。Message msg = queue.next();这个,用脚趾头想也是从队列中取出消息。不看了。 msg.target.dispatchMessage(msg);msg.target,就是handler。
handler.dispatchMessage如下:
1 public void dispatchMessage(Message msg) { 2 if (msg.callback != null) { 3 handleCallback(msg); 4 } else { 5 if (mCallback != null) { 6 if (mCallback.handleMessage(msg)) { 7 return; 8 } 9 } 10 handleMessage(msg); 11 } 12 }
这个,看到了我们熟悉的handleMessage。
收工。
标签:android style blog io ar color 使用 sp for
原文地址:http://www.cnblogs.com/yaq812/p/4164951.html