Handle源码分析与理解-六虎

我们知道，不论时我们还是系统，在进行线程间通信都会用到handler，也就是消息机制。

一般情况下耗时操作放在子线程里，更新UI放在主线程里，一旦子线程完成耗时操作，就要回到主线程去更新UI了，这时就要用到Handler了。

Handler：消息的控制器
Message：消息的载体
MessageQueue:存放消息
Looper：控制消息队列的循环
简单展示一下Handler的用法

private Handler handler = new Handler(){
    @Override
    public void handleMessage(Message msg) {
         super.handleMessage(msg);
         textView.setText("success");
    }
};
@Override
protected void onCreate(Bundle savedInstanceState){
       super.onCreate(savedInstanceState);
       setContentView(R.layout.activity_main);
       textView = (TextView) findViewById(R.id.tv_handler);
       new Thread(new Runnable() {
           @Override
           public void run() {
               //模拟耗时操作
               SystemClock.sleep(3000);
               handler.sendMessage(new Message());
           }
       }).start();
   }

可以看到我们在子线程发送消息，然后Handler接收消息进行操作，接下来我们来看看一下他的源码。

首先跟踪到sendMessage，可以看到无论是sendMessage还是sendEmptyMessage，最后都会进入到sendMessageDelayed。只不过sendEmptyMessage需要传一个what的值，具体是调用obtain方法获取一个message，将what值赋值给它

public final boolean sendMessage(@NonNull Message msg) {
    return sendMessageDelayed(msg, 0);
}
public final boolean sendEmptyMessage(int what)
{
    return sendEmptyMessageDelayed(what, 0);
}
public final boolean sendEmptyMessageDelayed(int what, long delayMillis) {
    Message msg = Message.obtain();
    msg.what = what;
    return sendMessageDelayed(msg, delayMillis);
}

为什么不new一个message呢，我们来看看obtain()，是怎么做的？

public static Message obtain() {
    synchronized (sPoolSync) {
        if (sPool != null) {
            Message m = sPool;
            sPool = m.next;
            m.next = null;
            m.flags = 0; // clear in-use flag
            sPoolSize--;
            return m;
        }
    }
    return new Message();
}

发现原来已经定义好了一个massage池，如果了解数据结构的话，能看出来这是一个链表结构，我们直接从里面取就可以
接着继续看sendMessageDelayed()

public final boolean sendMessageDelayed(@NonNull Message msg, long delayMillis) {
    if (delayMillis < 0) {
        delayMillis = 0;
    }
    return sendMessageAtTime(msg, SystemClock.uptimeMillis() + delayMillis);
}

这里校正了一下时间，继续看sendMessageAtTime

public boolean sendMessageAtTime(@NonNull 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);
}

这里判断一下messageQueue是否为空，不为空就一切正常，然后把消息放入消息队列中，继续看enqueueMessage()是如何插入消息的

private boolean enqueueMessage(@NonNull MessageQueue queue, @NonNull Message msg,
        long uptimeMillis) {
    msg.target = this;
    msg.workSourceUid = ThreadLocalWorkSource.getUid();
    if (mAsynchronous) {
        msg.setAsynchronous(true);
    }
    return queue.enqueueMessage(msg, uptimeMillis);
}

先将msg的目标指向自己，然后设置为同步消息，这样由于同步屏障的机制，UI绘制也会更流畅，接着入队

boolean enqueueMessage(Message msg, long when) {
    if (msg.target == null) {
        throw new IllegalArgumentException("Message must have a target.");
    }
    synchronized (this) {
        if (msg.isInUse()) {
            throw new IllegalStateException(msg + " This message is already in use.");
        }
        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;
}

这也是一个链表结构。首先会对链表头指针做判断，如果为空，那么就把当前消息插入到链表头部，如果链表不为空，那么比较一下当前消息的执行时间，若时间小于头指针所存储的消息，那么也要将他插入到链表头部。若以上条件都不满足，那么就要对链表进行一个遍历，找到适当的位置并插入。

Looper
looper负责取出消息交给handler，它是怎么工作的？

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));
}

一个线程只能有一个looper，然后它new looper传递给sThreadLocal.set()中，看看这个方法：

public void set(T value) {
    Thread t = Thread.currentThread();
    ThreadLocalMap map = getMap(t);
    if (map != null)
        map.set(this, value);
    else
        createMap(t, value);
}

这里是创建了一个表，key是当前线程，value是这个新建的looper
再看看Looper的构造方法：

private Looper(boolean quitAllowed) {
    mQueue = new MessageQueue(quitAllowed);
    mThread = Thread.currentThread();
}

总体上好像就是把线程，looper，queue三者对应起来了，接下来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.");
    }
    if (me.mInLoop) {
        Slog.w(TAG, "Loop again would have the queued messages be executed"
                + " before this one completed.");
    }
    me.mInLoop = true;
    // 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();
    // Allow overriding a threshold with a system prop. e.g.
    // adb shell 'setprop log.looper.1000.main.slow 1 && stop && start'
    final int thresholdOverride =
            SystemProperties.getInt("log.looper."
                    + Process.myUid() + "."
                    + Thread.currentThread().getName()
                    + ".slow", 0);
    // 要判断一下线程是否切换了
    me.mSlowDeliveryDetected = false;
    for (;;) {
        if (!loopOnce(me, ident, thresholdOverride)) {
            return;
        }
    }
}

这里显示判断了一下looper是否为空，然后应该是对该线程进行校验，然后开始死循环直到loopOnce()返回false，那我们看看什么时候返回false

private static boolean loopOnce(final Looper me,
        final long ident, final int thresholdOverride) {
    Message msg = me.mQueue.next(); // might block
    if (msg == null) {
        // No message indicates that the message queue is quitting.
        return false;
    }
    // ......
    try {
        msg.target.dispatchMessage(msg);
        if (observer != null) {
            observer.messageDispatched(token, msg);
        }
        dispatchEnd = needEndTime ? SystemClock.uptimeMillis() : 0;
    } catch (Exception exception) {
        if (observer != null) {
            observer.dispatchingThrewException(token, msg, exception);
        }
        throw exception;
    } finally {
        ThreadLocalWorkSource.restore(origWorkSource);
        if (traceTag != 0) {
            Trace.traceEnd(traceTag);
        }
    }
    // ......
    msg.recycleUnchecked();
    return true;
}

这段代码好长，基本上就是检查线程是否切换，性能分析相关的东西。精简一下就是这个样子，msg.target上面说到就是handler，可以看出dispatchMessage()挺重要的

public void dispatchMessage(@NonNull Message msg) {
    if (msg.callback != null) {
        handleCallback(msg);
    } else {
        if (mCallback != null) {
            if (mCallback.handleMessage(msg)) {
                return;
            }
        }
        handleMessage(msg);
    }
}

handleMessage就是我们例子中的覆盖的那个方法，它其实是一个空方法，要我们去做逻辑处理
到这里就分析完了，总结一下：

handler与messageQueue与looper与线程是多对一对一对一的关系。
message中主要的成员变量有target(目标Handler)，obj(Object类型的数据)，data(Bundle类型的数据)，what(message的id)，flag(同步或是异步消息)
创建Message对象尽量用obtain()方法，这样是从一个消息池中不断的取出消息来使用，避免过多的内存分配
主线程在一开始创建时就已经创建并开启了Looper，所以我们在主线程中使用Handler时就已经和主线程、消息队列有了联系，就不用再手动调用loop()了。而在子线程，我们需要先looper.prepare(),把looper和该线程保存起来，然后再loop()取出
文章开头流程：在子线程中，借用主线程的handler发送一条消息，此时还在子线程中，只不过发送的消息会放在主线程的looper循环执行

Handle源码分析与理解

相关文章

下一代的智能合约编程语言Move（五）

Sqoop入门：如何下载、配置和使用

测试用例千万不能随便，记录由一个测试用例异常引起的思考

langchain:Prompt在手,天下我有

作者信息