标签:
说到Handler想必大家都经常用到,在非UI线程更新UI那可是利器,用起来也非常容易上手
从使用上来说,我们只需要关注sendMessage和handleMessage即可
所以我们先从Handler和Message来说起,先看一小段代码
public static final int UPDATE_TEXT_VIEW = 0; public TextView mResultTextView = null; // new 一个 Handler 对象, 以内部类的方式重写 handleMessage 这个函数 public Handler mMyHandler = new Handler() { // ③ 处理消息 public void handleMessage(android.os.Message msg) { switch (msg.what) { case UPDATE_TEXT_VIEW: /* 这里可更新 ui */ mResultTextView.setText(String.valueOf(msg.arg1)); break; default: /* do nothing */ break; } }; }; // ================================================================== // 函数名: calc // 日期: 2015-08-30 // 功能: 计算入参并显示在 UI 上,然后后续以每秒 +1 在 UI 上更新 // 输入参数: int a // int b // 返回值: 无 // 修改记录:千里草新增函数 // ================================================================== public void calc(int a, int b) { int c = a + b; final Message msg = new Message(); msg.what = UPDATE_TEXT_VIEW; msg.arg1 = c; // ① 发送消息 mMyHandler.sendMessage(msg); // 这里更新 UI 线程的TextView OK // mResultTextView.setText(String.valueOf(msg.arg1)); // 启动一个新的线程来每秒刷新 TextView new Thread() { public void run() { while (true) { msg.arg1++; // ② 发送消息 mMyHandler.sendMessage(msg); // mResultTextView.setText(String.valueOf(msg.arg1)); 这里会报错 try { sleep(1000); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } } }; }.start(); }
代码中有①,②两处发送消息,. 分别是从UI线程和从子线程发送的消息, 在③处两个消息都可以被准确的接收到.
在接受消息函数handleMessage 里我们可以做任何想做的事情,包括更新UI…
从使用来说,大家根据这个例子,想必已经可以简单使用Handler来处理多线程之间的交互了…
此处需要注意的是在使用Handler时,必须需要重写handleMessage 才能达到我们想达到的目的...(从逻辑上来说,没有接受消息的地方,发送的消息有何意义呢,是吧….从原理上..我们接下来会谈到……)
谈到Handler,我们还可以用它执行一个Runnable多线程…例如下面的代码..
mMyHandler.post(new Runnable() { @Override public void run() { // 这里需要注意的是,calc 是在子线程里被调用,所以calc 就无法操作 UI 了. calc(1, 2); } });
Handler可真神奇,既可以发消息也可以执行某个任务线程.
为了更深层次的了解它,只能去看看它的源码了.let’s go!
先看看是如何post一个Runnable线程的
public final boolean post(Runnable r) { //这里实际上是发送了一个Message return sendMessageDelayed(getPostMessage(r), 0); } //组装一个只带Runnable的Message private static Message getPostMessage(Runnable r) { Message m = Message.obtain(); m.callback = r; return m; } //发送消息 public final boolean sendMessageDelayed(Message msg, long delayMillis) { if (delayMillis < 0) { delayMillis = 0; } return sendMessageAtTime(msg, SystemClock.uptimeMillis() + delayMillis); }
哎哟喂,这Handler小丫头片子,还假装两幅面孔呢, 经查看源码,发现它实际上是发送了一个Message消息,然而这个消息仅仅携带了一个Runnable对象.
现在来看只需要分析Handler和Message了..我们来看看最终Handler是如何发送消息的..我们继续看源码,非得把他们扒个精光不可
public boolean sendMessageAtTime(Message msg, long uptimeMillis) { boolean sent = false; //消息队列,这里存储Handler发送的消息 MessageQueue queue = mQueue; if (queue != null) { //Message与Handler绑定 msg.target = this; //消息进队列 sent = queue.enqueueMessage(msg, uptimeMillis); } else { RuntimeException e = new RuntimeException( this + " sendMessageAtTime() called with no mQueue"); Log.w("Looper", e.getMessage(), e); } return sent; }
从消息最终被发出的函数来看,这里只做了两个事情:
1.Message与Handler绑定
2.将Message放进消息队列里
消息进队列之后,Handler发送消息的任务算是完美的完成了,接下来我们该介绍介绍Looper了,如果没有Looper,Handler和Message之间的爱情可以说是不完整的.
我们先来看看一个Looper是如何使用的吧
class LooperThread extends Thread { public Handler mHandler; public void run() { // 为当前线程准备一个 Looper Looper.prepare(); mHandler = new Handler() { public void handleMessage(Message msg) { // 处理消息 } }; // Looper 开始工作 Looper.loop(); } }
//继续看源码,prepare执行之后sThreadLocal绑定一个Looper对象 //sThreadLocal 能且只能绑定一个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)); } /** * 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循环,来遍历Messagequeue 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 Printer logging = me.mLogging; if (logging != null) { logging.println(">>>>> Dispatching to " + msg.target + " " + msg.callback + ": " + msg.what); } //Message绑定的Handler来开始处理消息.. 下面贴上dispatchMessage,函数,大家继续往下看 msg.target.dispatchMessage(msg); 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.recycle(); } } /** * Callback interface you can use when instantiating a Handler to avoid * having to implement your own subclass of Handler. */ public interface Callback { public boolean handleMessage(Message msg); } /** * Subclasses must implement this to receive messages. * 子类必须完成handleMessage这个函数来接收消息 */ public void handleMessage(Message msg) { } /** * Handle system messages here. */ public void dispatchMessage(Message msg) { //收到消息后,先处理Runnable 对象callback. if (msg.callback != null) { handleCallback(msg); } else { //如果这里有回调接口,那么就直接调用该接口,不再继续调用Handler的handleMessage函数来处理消息 if (mCallback != null) { if (mCallback.handleMessage(msg)) { return; } } handleMessage(msg); } }
从上述加了中文注释的代码中能看出,Handler发送的Message通过Looper分发给了各自的Handler.
所以上面说的在使用Handler时,必须需要重写handleMessage 才能达到我们想达到的目的...也不完全正确,
我们也可以实现一个CallBack接口来处理消息,用Google的原话是
/** * Callback interface you can use when instantiating a Handler to avoid * having to implement your own subclass of Handler. */ public interface Callback { public boolean handleMessage(Message msg); }
再贴最后一段代码来彻彻底底说明Handler Looper之间的关系, 那就是Handler的 构造函数
/** * Default constructor associates this handler with the queue for the * current thread. * * If there isn‘t one, this handler won‘t be able to receive messages. */ public Handler() { if (FIND_POTENTIAL_LEAKS) { final Class<? extends Handler> klass = getClass(); if ((klass.isAnonymousClass() || klass.isMemberClass() || klass.isLocalClass()) && (klass.getModifiers() & Modifier.STATIC) == 0) { Log.w(TAG, "The following Handler class should be static or leaks might occur: " + klass.getCanonicalName()); } } //绑定当前线程的Looper 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 = null; }
一句话总结来说,Handler初始化时绑定了线程的MessageQueue,当前线程的Looper来依次分发MessageQueue里的消息.
MessageQueue的消息会根据Message的target绑定的Handler被Looper分发到各自的Handler里去处理.
例如Activity里有两个HandlerA和HandlerB, HandlerA发送的消息绝对不可能被HandlerB处理..
先暂时写到这里吧,后续补上流程图和类图
上述只是个人的很片面的理解,希望大家补充和指出不足的地方…
2015年9月4日 04:10:05 千里草
Handler和Message以及Looper之间的三角关系
标签:
原文地址:http://www.cnblogs.com/darin726/p/4781181.html