美文网首页
Handler、Looper源码浅析

Handler、Looper源码浅析

作者: 匿名用户_bcc3 | 来源:发表于2018-12-09 21:02 被阅读0次

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从子线程传递到主线程了。

相关文章

网友评论

      本文标题:Handler、Looper源码浅析

      本文链接:https://www.haomeiwen.com/subject/hekkhqtx.html