Android - Handler 消息机制

概述#

Android 的消息机制主要是指 Handler 的运行机制以及 Handler 所附带的 MessageQueue 和 Looper 的工作过程。 Handler 的主要作用是将某个任务切换到 Handler 所在的线程中去执行。

Handler机制#

Handler工作流程 Looper 每个线程中最多只能有一个 Looper 对象，由 Looper 来管理此线程里的 MessageQueue (消息队列)。可以通过 Looper.myLooper() 获取当前线程的 Looper 实例，通过 Looper.getMainLooper() 获取主（UI）线程的 Looper 实例。 Lopper 会以无限循环的形式去查找是否有新消息，如果有就处理消息，否则就一直等待着。 Handler 你可以构造 Handler 对象来与 Looper 沟通，通过 push 发送新消息到 MessageQueue 里；或者通过 handleMessage 接收 Looper 从 MessageQueue 取出来消息。 MessageQueue MessageQueue是一个消息队列，内部存储了一组消息，以队列的形式对外提供插入和删除的工作，内部采用单链表的数据结构来存储消息列表。 ActivityThread 我们经常提到的主线程，也叫UI线程，它就是 ActivityThread，主线程启动会默认初始化一个 Looper 并创建 Handler。 一个线程中只有一个 Looper 实例，一个 MessageQueue 实例，可以有多个 Handler 实例。 ThreadLocal 一个线程内部的数据存储类，通过它可以在指定线程中存储数据，数据存储后，只有在指定线程中可以获取到存储的数据，对于其他线程来说无法获得数据。对于 Handler 来说，它需要获取当前线程的 Looper ,而 Looper 的作用于就是线程并且不同的线程具有不同的 Looper ，通过 ThreadLocal 可以轻松实现线程中的存取。 ThreadLocal原理：不同线程访问同一个ThreadLoacl的get方法，ThreadLocal的get方法会从各自的线程中取出一个数组，然后再从数组中根据当前ThreadLocal的索引去查找对应的Value值。

源码分析#

通过上面分析我们知道使用 Handler 之前必须先调用 Looper.prepare(); 进行初始化，我们先看下 Looper 的源码。

1. Looper 工作原理#

先看一下 Looper 工作流程 Looper 源码最上面的注释里有一个使用示例如下，可以清晰的看出 Looper 的使用方法。

1
class LooperThread extends Thread {
2
     public Handler mHandler;
3
     public void run() {
4
         Looper.prepare();//先初始化 Looper
5
         mHandler = new Handler() {//创建 Handler
6
             public void handleMessage(Message msg) {
7
                 // process incoming messages here
8
             }
9
         };
10
         Looper.loop();//启用 Looper 的 loop 方法开启消息轮询
11
     }
12
}

接续看一下 Looper 的完整源码，分析下工作过程。

1
public final class Looper {
2

3
    static final ThreadLocal<Looper> sThreadLocal = new ThreadLocal<Looper>();
4
  //每个线程都会有一个ThreadLocal 用来保存 Looper对象（里面包含了主线程和 MessageQueue）
5

6
    private static Looper sMainLooper;  // 主线程的 Looper
7

8
    final MessageQueue mQueue;//保存消息队列
9
    final Thread mThread;//保存主线程
10

11
    public static void prepare() {//为当前线程创建 Looper
12
        prepare(true);
13
    }
14

15
    private static void prepare(boolean quitAllowed) {
16
        if (sThreadLocal.get() != null) {
17
      //一个线程只能有一个 Looper， 否则抛出异常
18
            throw new RuntimeException("Only one Looper may be created per thread");
19
        }
20
        sThreadLocal.set(new Looper(quitAllowed));//将创建的 Looper 放入 ThreadLocal
21
    }
22

23
  //初始化主线程的 Looper
24
    public static void prepareMainLooper() {
25
        prepare(false);
26
        synchronized (Looper.class) {
27
            if (sMainLooper != null) {
28
                throw new IllegalStateException("The main Looper has already been prepared.");
29
            }
30
            sMainLooper = myLooper();
31
        }
32
    }
33

34
    //获取主线程的 Looper
35
    public static Looper getMainLooper() {
36
        synchronized (Looper.class) {
37
            return sMainLooper;
38
        }
39
    }
40

41
    //在当前线程中开启轮询
42
    public static void loop() {
43
        final Looper me = myLooper();//从 ThreadLocal 中取出当前线程的 Looper 对象
44
        if (me == null) {
45
      //Looper 没有调用 Looper.prepare() 初始化，抛出异常
46
            throw new RuntimeException("No Looper; Looper.prepare() wasn't called on this thread.");
47
        }
48
        final MessageQueue queue = me.mQueue;//从 Looper 对象中取出消息队列
49

50
        for (;;) {//死循环
51
            Message msg = queue.next(); // 不断的取出消息
52
            if (msg == null) {
53
                // No message indicates that the message queue is quitting.
54
                return;
55
            }
56

57
      ...
58

59
            try {
60
                msg.target.dispatchMessage(msg);
61
        //取出消息的 target (也就是 Handler)，执行分发消息的操作
62
            } finally {
63
                if (traceTag != 0) {
64
                    Trace.traceEnd(traceTag);
65
                }
66
            }
67

68
      ...
69

70
            msg.recycleUnchecked();//消息已经分发，进行回收操作
71
        }
72
    }
73

74
    public static @Nullable Looper myLooper() {
75
        return sThreadLocal.get();//从 ThreadLocal 中取出当前线程的 Looper 对象
76
    }
77

78
    private Looper(boolean quitAllowed) {
79
        mQueue = new MessageQueue(quitAllowed);//创建消息队列
80
        mThread = Thread.currentThread();//保存当前线程
81
    }
82

83
    public void quit() {
84
        mQueue.quit(false);//直接退出消息循环，不管是否还有消息
85
    }
86

87
    public void quitSafely() {
88
        mQueue.quit(true);//执行完所有的消息，退出消息循环
89
    }
90

91
  ...
92
}

2. MessageQueue 工作原理#

在 Looper 中创建了 MessageQueue，我们接着看下 MessageQueue 是怎么工作的。 MessageQueue 工作流程 MessageQueue的构造方法。

1
MessageQueue(boolean quitAllowed) {
2
    mQuitAllowed = quitAllowed;
3
  //构造函数，quitAllowed 用来标识是否允许退出。
4
  //主线程是不允许退出的（不然会退出整个程序），子线程可以退出。
5
    mPtr = nativeInit();
6
}

然后我们再看一下 MessageQueue.enqueueMessage() 的源码，分析下是怎么添加消息的。

1
boolean enqueueMessage(Message msg, long when) {
2
    if (msg.target == null) {
3
        throw new IllegalArgumentException("Message must have a target.");
4
    }
5
    if (msg.isInUse()) {
6
        throw new IllegalStateException(msg + " This message is already in use.");
7
    }
8

9
    synchronized (this) {
10
        if (mQuitting) {
11
            IllegalStateException e = new IllegalStateException(
12
                    msg.target + " sending message to a Handler on a dead thread");
13
            Log.w(TAG, e.getMessage(), e);
14
            msg.recycle();
15
            return false;
16
        }
17

18
        msg.markInUse();
19
        msg.when = when;
20
        Message p = mMessages;
21
        boolean needWake;
22
        if (p == null || when == 0 || when < p.when) {
23
            // 如果消息队列里面没有消息，或者消息的执行时间比里面的消息早，就把这条消息设置成第一条消息。
24
      //一般不会出现这种情况，因为系统一定会有很多消息。
25
            msg.next = p;
26
            mMessages = msg;
27
            needWake = mBlocked;
28
        } else {//如果消息队列里面有消息
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
        // We can assume mPtr != 0 because mQuitting is false.
46
        if (needWake) {
47
            nativeWake(mPtr);
48
        }
49
    }
50
    return true;
51
}

知道了怎么添加消息，我们再看下 MessageQueue.next() 方法是怎么取出消息的，也就是 Looper.loop() 方法中不断取消息的方法。

1
Message next() {
2
    int pendingIdleHandlerCount = -1; // -1 only during first iteration
3
    int nextPollTimeoutMillis = 0;
4
    for (;;) {
5
        if (nextPollTimeoutMillis != 0) {
6
            Binder.flushPendingCommands();
7
        }
8

9
        nativePollOnce(ptr, nextPollTimeoutMillis);
10

11
        synchronized (this) {
12
            final long now = SystemClock.uptimeMillis();
13
            Message prevMsg = null;
14
            Message msg = mMessages;//拿到当前的消息队列
15
            if (msg != null && msg.target == null) {
16
                //处理异步的消息，暂不讨论
17
                do {
18
                    prevMsg = msg;
19
                    msg = msg.next;
20
                } while (msg != null && !msg.isAsynchronous());
21
            }
22
            if (msg != null) {
23
                if (now < msg.when) {
24
                    // Next message is not ready.  Set a timeout to wake up when it is ready.
25
                    nextPollTimeoutMillis = (int) Math.min(msg.when - now, Integer.MAX_VALUE);
26
                } else {
27
                    //取出一条消息，消息队列往后移动一个
28
                    mBlocked = false;
29
                    if (prevMsg != null) {
30
                        prevMsg.next = msg.next;
31
                    } else {
32
                        mMessages = msg.next;
33
                    }
34
                    msg.next = null;
35
                    if (DEBUG) Log.v(TAG, "Returning message: " + msg);
36
                    msg.markInUse();//标记为已使用
37
                    return msg;
38
                }
39
            } else {
40
                // No more messages.
41
                nextPollTimeoutMillis = -1;
42
            }
43

44
            ...
45
    }
46
}

我们知道 MessageQueue 是个链表结构，里面保存的是 Message，我们再看下 Message 是什么。

1
public final class Message implements Parcelable {
2

3
    public int what;//消息类型，标识消息的作用
4

5
    public int arg1;//整型参数1
6

7
    public int arg2;//整型参数2
8

9
    public Object obj;//复杂对象参数
10

11
    public Messenger replyTo;
12

13
    public int sendingUid = -1;
14

15
  /*package*/ static final int FLAG_IN_USE = 1 << 0;//标记消息已使用
16

17
    /** If set message is asynchronous */
18
    /*package*/ static final int FLAG_ASYNCHRONOUS = 1 << 1;//标记消息是否异步
19

20
    /** Flags to clear in the copyFrom method */
21
    /*package*/ static final int FLAGS_TO_CLEAR_ON_COPY_FROM = FLAG_IN_USE;
22

23
    /*package*/ int flags;//消息当前标记
24

25
    /*package*/ long when;//消息执行时间
26

27
    /*package*/ Bundle data;
28

29
    /*package*/ Handler target;//Handler 用于执行 handleMessage();
30

31
    /*package*/ Runnable callback;//消息是一个Runnable
32

33
    // sometimes we store linked lists of these things
34
    /*package*/ Message next;//下一个消息
35

36
    private static final Object sPoolSync = new Object();//控制并发访问
37
    private static Message sPool;//消息池
38
    private static int sPoolSize = 0;//消息池数量
39

40
    private static final int MAX_POOL_SIZE = 50;//消息最大数量
41

42
    ...
43

44
}

3. Handler 工作原理#

在 Message 中我们看到了 target 是一个 Handler，我们看下 Handler 是怎么与 Looper 和 MessageQueue 一起搭配工作的。看一下 Handler 的源码。

1
public class Handler {
2

3
    public interface Callback {
4
        public boolean handleMessage(Message msg);
5
    }
6

7

8
    public void handleMessage(Message msg) {}
9

10
    /**
11
     * 消息处理
12
     */
13
    public void dispatchMessage(Message msg) {
14
        if (msg.callback != null) {//如果消息体是 Runnable 就执行 run()
15
            handleCallback(msg);
16
        } else {
17
            if (mCallback != null) {
18
        //如果创建 Handler 时传入了 Callback，就执行 Callback 里面的逻辑
19
                if (mCallback.handleMessage(msg)) {
20
                    return;
21
                }
22
            }
23
            handleMessage(msg);//如果上述两种都没有实现，就执行 handleMessage 的逻辑
24
        }
25
    }
26

27

28
    public Handler() {
29
        this(null, false);
30
    }
31

32
    public Handler(Callback callback) {
33
        this(callback, false);
34
    }
35

36
    public Handler(Looper looper) {//可以指定关联哪个线程的 Looper
37
        this(looper, null, false);
38
    }
39

40
    public Handler(Looper looper, Callback callback) {
41
        this(looper, callback, false);
42
    }
43

44
    public Handler(boolean async) {
45
        this(null, async);
46
    }
47

48
  /**
49
     * 主线程调用的构造方法，主线程已经调用了 Looper.prepareMainLooper();
50
     *
51
     * @hide
52
     */
53
    public Handler(Callback callback, boolean async) {
54
        if (FIND_POTENTIAL_LEAKS) {
55
            final Class<? extends Handler> klass = getClass();
56
            if ((klass.isAnonymousClass() || klass.isMemberClass() || klass.isLocalClass()) &&
57
                    (klass.getModifiers() & Modifier.STATIC) == 0) {
58
                Log.w(TAG, "The following Handler class should be static or leaks might occur: " +
59
                    klass.getCanonicalName());
60
            }
61
        }
62

63
        mLooper = Looper.myLooper();//取出主线程的 Looper
64
        if (mLooper == null) {
65
            throw new RuntimeException(
66
                "Can't create handler inside thread that has not called Looper.prepare()");
67
        }
68
        mQueue = mLooper.mQueue;//把 Handler 的 mQueue 指向 Looper 中的 mQueue
69
        mCallback = callback;
70
        mAsynchronous = async;
71
    }
72

73
    /**
74
     * 第二种构造方法，专门给子线程中创建 Handler 时使用的
75
     *
76
     * @hide
77
     */
78
    public Handler(Looper looper, Callback callback, boolean async) {
79
        mLooper = looper;
80
        mQueue = looper.mQueue;
81
        mCallback = callback;
82
        mAsynchronous = async;
83
    }
84

85
    //发送 Runnable 消息
86
    public final boolean post(Runnable r){
87
       return  sendMessageDelayed(getPostMessage(r), 0);
88
    }
89

90
  private static Message getPostMessage(Runnable r) {
91
        Message m = Message.obtain();
92
        m.callback = r;
93
        return m;
94
    }
95

96
  //一般更新 UI 时发送的消息，延时时间为0
97
    public final boolean sendMessage(Message msg){
98
        return sendMessageDelayed(msg, 0);
99
    }
100

101
    //发送延时消息
102
    public final boolean sendMessageDelayed(Message msg, long delayMillis){
103
        if (delayMillis < 0) {
104
            delayMillis = 0;
105
        }
106
        return sendMessageAtTime(msg, SystemClock.uptimeMillis() + delayMillis);
107
    }
108

109
    //发送指定时间发送的消息
110
    public boolean sendMessageAtTime(Message msg, long uptimeMillis) {
111
        MessageQueue queue = mQueue;
112
        if (queue == null) {
113
            RuntimeException e = new RuntimeException(
114
                    this + " sendMessageAtTime() called with no mQueue");
115
            Log.w("Looper", e.getMessage(), e);
116
            return false;
117
        }
118
        return enqueueMessage(queue, msg, uptimeMillis);
119
    }
120

121

122
    private boolean enqueueMessage(MessageQueue queue, Message msg, long uptimeMillis) {
123
        msg.target = this;
124
    //把字节传入 Message 中一起发送
125
    //Looper 中需要使用 Handler 来执行 dispatchMessage 方法
126
        if (mAsynchronous) {
127
            msg.setAsynchronous(true);
128
        }
129
        return queue.enqueueMessage(msg, uptimeMillis);
130
    }
131

132
}

4. ActivityThread 创建默认的 Handler#

上面说过，ActivityThread 主线程默认是有一个 Handler 的，我们来看一下主线程是怎么创建默认的 Handler 的。我们看一下 ActivityThread 类中的 main 方法。

1
public static void main(String[] args) {
2
    Trace.traceBegin(Trace.TRACE_TAG_ACTIVITY_MANAGER, "ActivityThreadMain");
3
    SamplingProfilerIntegration.start();
4

5
    // CloseGuard defaults to true and can be quite spammy.  We
6
    // disable it here, but selectively enable it later (via
7
    // StrictMode) on debug builds, but using DropBox, not logs.
8
    CloseGuard.setEnabled(false);
9

10
    Environment.initForCurrentUser();//准备一些相关环境，给我们的组件启动
11

12
    // Set the reporter for event logging in libcore
13
    EventLogger.setReporter(new EventLoggingReporter());
14

15
    // Make sure TrustedCertificateStore looks in the right place for CA certificates
16
    final File configDir = Environment.getUserConfigDirectory(UserHandle.myUserId());
17
    TrustedCertificateStore.setDefaultUserDirectory(configDir);
18

19
    Process.setArgV0("<pre-initialized>");
20

21
    Looper.prepareMainLooper();//初始化主线程 Looper
22

23
    ActivityThread thread = new ActivityThread();
24
    thread.attach(false);
25

26
    if (sMainThreadHandler == null) {
27
        sMainThreadHandler = thread.getHandler();
28
    }
29

30
    if (false) {
31
        Looper.myLooper().setMessageLogging(new
32
                LogPrinter(Log.DEBUG, "ActivityThread"));
33
    }
34

35
    // End of event ActivityThreadMain.
36
    Trace.traceEnd(Trace.TRACE_TAG_ACTIVITY_MANAGER);
37
    Looper.loop();//开启消息轮询，不断取出消息
38

39
    throw new RuntimeException("Main thread loop unexpectedly exited");
40
}

在 Activity 可以直接用 runOnUiThread() 来使用默认的 Handler 发送消息，我们来看下它是怎么实现的。

1
public final void runOnUiThread(Runnable action) {
2
    if (Thread.currentThread() != mUiThread) {//非主线程，发送 Runnable 消息
3
        mHandler.post(action);
4
    } else {//在主线程中直接执行 run()
5
        action.run();
6
    }
7
}

5. HandlerThread 异步消息处理机制#

HandlerThread 继承了 Thread，是一种可以使用 Handler 的 Thread；
在 run 方法中通过 looper.prepare() 来开启消息循环，这样就可以在 HandlerThread 中创建Handler了；
外界可以通过一个 Handler 的消息方式来通知 HandlerThread 来执行具体任务；确定不使用之后，可以通过 quit 或 quitSafely 方法来终止线程执行。

先分析一下 HandlerThread 的源码。

1
public class HandlerThread extends Thread {
2
    //线程的优先级
3
    int mPriority;
4
    //线程的id
5
    int mTid = -1;
6
    //一个与Handler关联的Looper对象
7
    Looper mLooper;
8

9
    public HandlerThread(String name) {
10
        super(name);
11
        //设置优先级为默认线程
12
        mPriority = android.os.Process.THREAD_PRIORITY_DEFAULT;
13
    }
14

15
    public HandlerThread(String name, int priority) {
16
        super(name);
17
        mPriority = priority;
18
    }
19
    //可重写方法，Looper.loop之前在线程中需要处理的其他逻辑在这里实现
20
    protected void onLooperPrepared() {
21
    }
22
    //HandlerThread线程的run方法
23
    @Override
24
    public void run() {
25
        //获取当前线程的id
26
        mTid = Process.myTid();
27
        //创建Looper对象
28
        //这就是为什么我们要在调用线程的start()方法后才能得到Looper(Looper.myLooper不为Null)
29
        Looper.prepare();
30
        //同步代码块，当获得mLooper对象后，唤醒所有线程
31
        synchronized (this) {
32
            mLooper = Looper.myLooper();
33
            notifyAll();
34
        }
35
        //设置线程优先级
36
        Process.setThreadPriority(mPriority);
37
        //Looper.loop之前在线程中需要处理的其他逻辑
38
        onLooperPrepared();
39
        //建立了消息循环
40
        Looper.loop();
41
        //一般执行不到这句，除非quit消息队列
42
        mTid = -1;
43
    }
44

45
    public Looper getLooper() {
46
        if (!isAlive()) {
47
            //线程死了
48
            return null;
49
        }
50

51
        //同步代码块，正好和上面run方法中同步块对应
52
        //只要线程活着并且mLooper为null，则一直等待
53
        // If the thread has been started, wait until the looper has been created.
54
        synchronized (this) {
55
            while (isAlive() && mLooper == null) {
56
                try {
57
                    wait();
58
                } catch (InterruptedException e) {
59
                }
60
            }
61
        }
62
        return mLooper;
63
    }
64

65
    public boolean quit() {
66
        Looper looper = getLooper();
67
        if (looper != null) {
68
            //退出消息循环
69
            looper.quit();
70
            return true;
71
        }
72
        return false;
73
    }
74

75
    public boolean quitSafely() {
76
        Looper looper = getLooper();
77
        if (looper != null) {
78
            //退出消息循环
79
            looper.quitSafely();
80
            return true;
81
        }
82
        return false;
83
    }
84

85
    public int getThreadId() {
86
        //返回线程id
87
        return mTid;
88
    }
89
}

HandlerThread 使用代码示例

1
public class MainActivity extends AppCompatActivity {
2

3
  private HandlerThread mHandlerThread = null;
4
    private Handler mThreadHandler = null;
5
    private Handler mUiHandler = null;
6

7
   @Override
8
    protected void onCreate(Bundle savedInstanceState) {
9
        super.onCreate(savedInstanceState);
10
        setContentView(R.layout.activity_main);
11

12
    mHandlerThread = new HandlerThread("HandlerWorkThread");
13
        //必须在实例化mThreadHandler之前调运start方法，原因上面源码已经分析了
14
        mHandlerThread.start();
15
        //将当前mHandlerThread子线程的Looper传入mThreadHandler，使得
16
        //mThreadHandler的消息队列依赖于子线程（在子线程中执行）
17
        mThreadHandler = new Handler(mHandlerThread.getLooper()) {
18
            @Override
19
            public void handleMessage(Message msg) {
20
                super.handleMessage(msg);
21
                Log.i(null, "在子线程中处理！id="+Thread.currentThread().getId());
22
                //从子线程往主线程发送消息
23
                mUiHandler.sendEmptyMessage(0);
24
            }
25
        };
26

27
        mUiHandler = new Handler() {
28
            @Override
29
            public void handleMessage(Message msg) {
30
                super.handleMessage(msg);
31
                Log.i(null, "在UI主线程中处理！id="+Thread.currentThread().getId());
32
            }
33
        };
34
        //从主线程往子线程发送消息
35
        mThreadHandler.sendEmptyMessage(1);
36

37
    }
38
}

总结#

到此 Handler 消息机制的源码已经分析完了，相信你一定明白了 Handler 消息机制。一句话，每个线程可以创建一个 Looper ，每个 Looper 轮询着一个 MessageQueue 不断取出消息，有消息则回调给 Handler，Handler 负责向 MessageQueue 中发送消息和处理回调的消息来完成线程之间的转换。