InterviewQuestion实战Handler、Looper、MessageQueue源码解析【免费下载链接】InterviewQuestion项目地址: https://gitcode.com/gh_mirrors/in/InterviewQuestion在Android开发中Handler、Looper、MessageQueue构成了核心的异步消息处理机制是保证UI线程不阻塞、实现组件间通信的关键。本文将从实战角度解析这三者的工作原理及源码实现帮助开发者深入理解Android消息循环机制。一、Handler机制核心组件关系Handler机制主要由Handler、Looper、MessageQueue和Message四个组件构成它们之间的关系可以概括为MessageQueue消息队列采用单链表结构存储消息负责按顺序管理消息Looper消息循环器不断从MessageQueue中取出消息并分发给对应HandlerHandler消息处理器负责发送消息和处理消息回调Message消息载体存储需要传递的数据和处理逻辑三者协同工作的基本流程是Handler发送Message到MessageQueueLooper循环读取MessageQueue中的消息并将消息分发给对应的Handler处理。二、Looper消息循环的核心引擎2.1 Looper的初始化过程每个线程只能有一个Looper实例通过Looper.prepare()方法初始化public static final void prepare() { if (sThreadLocal.get() ! null) { throw new RuntimeException(Only one Looper may be created per thread); } sThreadLocal.set(new Looper()); }主线程UI线程的Looper在应用启动时已由系统初始化查看ActivityThread的main方法public static void main(String[] args) { // ...省略其他代码 Looper.prepareMainLooper(); // 初始化主线程Looper // ...创建ActivityThread实例 Looper.loop(); // 启动消息循环 throw new RuntimeException(Main thread loop unexpectedly exited); }2.2 Looper的消息循环机制Looper通过loop()方法启动消息循环核心逻辑如下public static void loop() { final Looper me myLooper(); if (me null) { throw new RuntimeException(No Looper; Looper.prepare() wasnt called on this thread.); } final MessageQueue queue me.mQueue; // 无限循环读取消息 for (;;) { Message msg queue.next(); // 可能会阻塞 if (msg null) { // 消息为null表示消息队列正在退出 return; } // 分发消息到对应的Handler msg.target.dispatchMessage(msg); // 回收消息 msg.recycleUnchecked(); } }关键点当MessageQueue中没有消息时queue.next()会阻塞线程直到有新消息到来这也是为什么主线程不会因无限循环而ANR的原因。三、MessageQueue消息的有序管理者3.1 MessageQueue的数据结构MessageQueue内部采用单链表实现主要包含两个操作enqueueMessage将消息按时间顺序插入队列next取出并移除队头消息3.2 消息入队过程boolean enqueueMessage(Message msg, long when) { if (msg.target null) { throw new IllegalArgumentException(Message must have a target.); } if (msg.isInUse()) { throw new IllegalStateException(msg This message is already in use.); } synchronized (this) { msg.markInUse(); msg.when when; Message p mMessages; boolean needWake; // 根据时间戳插入到合适位置 if (p null || when 0 || when p.when) { // 队列为空或当前消息需要立即处理 msg.next p; mMessages msg; needWake mBlocked; } else { // 按时间顺序插入队列 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; prev.next msg; } // 如果需要唤醒线程 if (needWake) { nativeWake(mPtr); } } return true; }3.3 消息出队过程next()方法是一个可能阻塞的操作当队列中没有消息时线程会进入休眠状态Message next() { final long ptr mPtr; if (ptr 0) { return null; } int pendingIdleHandlerCount -1; // -1 only during first iteration int nextPollTimeoutMillis 0; for (;;) { if (nextPollTimeoutMillis ! 0) { Binder.flushPendingCommands(); } // 阻塞等待nextPollTimeoutMillis时间或被唤醒 nativePollOnce(ptr, nextPollTimeoutMillis); synchronized (this) { final long now SystemClock.uptimeMillis(); Message prevMsg null; Message msg mMessages; // 处理同步屏障消息 if (msg ! null msg.target null) { // 查找第一个异步消息 do { prevMsg msg; msg msg.next; } while (msg ! null !msg.isAsynchronous()); } if (msg ! null) { if (now msg.when) { // 消息还未到处理时间计算需要等待的时间 nextPollTimeoutMillis (int) Math.min(msg.when - now, Integer.MAX_VALUE); } else { // 取出消息 mBlocked false; if (prevMsg ! null) { prevMsg.next msg.next; } else { mMessages msg.next; } msg.next null; msg.markInUse(); return msg; } } else { // 没有消息无限等待 nextPollTimeoutMillis -1; } // 处理退出 if (mQuitting) { dispose(); return null; } // ...处理IdleHandler相关逻辑 } // ...执行IdleHandler nextPollTimeoutMillis 0; } }四、Handler消息的发送与处理4.1 Handler的创建Handler的构造方法有多种最常用的是无参构造public Handler() { this(null, false); } public Handler(Callback callback, boolean async) { // ...检查线程是否有Looper mLooper Looper.myLooper(); if (mLooper null) { throw new RuntimeException( Cant create handler inside thread Thread.currentThread() that has not called Looper.prepare()); } mQueue mLooper.mQueue; mCallback callback; mAsynchronous async; }注意在子线程中创建Handler必须先调用Looper.prepare()否则会抛出异常。4.2 消息发送Handler提供多种发送消息的方法最终都会调用enqueueMessageprivate boolean enqueueMessage(MessageQueue queue, Message msg, long uptimeMillis) { msg.target this; // 将当前Handler设为消息的target if (mAsynchronous) { msg.setAsynchronous(true); } return queue.enqueueMessage(msg, uptimeMillis); }常用的发送方法sendMessage(Message msg)立即发送消息sendEmptyMessage(int what)发送空消息sendMessageDelayed(Message msg, long delayMillis)延迟发送消息post(Runnable r)发送Runnable任务4.3 消息处理消息最终通过dispatchMessage方法分发处理public void dispatchMessage(Message msg) { if (msg.callback ! null) { // 处理post的Runnable handleCallback(msg); } else { if (mCallback ! null) { // 处理Callback接口 if (mCallback.handleMessage(msg)) { return; } } // 处理重写的handleMessage方法 handleMessage(msg); } } private static void handleCallback(Message message) { message.callback.run(); }消息处理优先级Runnable回调 Callback接口 重写handleMessage方法五、Handler机制实战应用5.1 子线程更新UI最常见的应用场景是在子线程中完成耗时操作后更新UI// 在UI线程创建Handler private Handler mHandler new Handler(Looper.getMainLooper()) { Override public void handleMessage(Message msg) { super.handleMessage(msg); // 更新UI操作 textView.setText(更新后的文本); } }; // 子线程中发送消息 new Thread(new Runnable() { Override public void run() { // 执行耗时操作 String result fetchDataFromNetwork(); // 发送消息到UI线程 Message msg mHandler.obtainMessage(1, result); mHandler.sendMessage(msg); } }).start();5.2 延迟任务执行使用postDelayed实现延迟执行任务// 延迟2秒执行 mHandler.postDelayed(new Runnable() { Override public void run() { // 执行延迟任务 showToast(2秒后执行); } }, 2000);5.3 主线程消息循环分析在Android应用开发中理解主线程消息循环有助于解决ANR问题。当主线程的MessageQueue中存在耗时超过5秒的消息时就会触发ANR。通过分析/data/anr/traces.txt文件可以查看ANR发生时主线程正在处理的消息。六、Handler机制常见问题6.1 内存泄漏问题当Handler作为Activity的内部类时会隐式持有Activity的引用如果Handler中有延迟消息可能导致Activity无法被回收。解决方法将Handler声明为静态内部类使用WeakReference引用Activity在Activity销毁时移除Handler的所有消息private static class MyHandler extends Handler { private WeakReferenceMainActivity mActivityRef; public MyHandler(MainActivity activity) { mActivityRef new WeakReference(activity); } Override public void handleMessage(Message msg) { MainActivity activity mActivityRef.get(); if (activity ! null) { // 处理消息 } } } // Activity销毁时移除消息 Override protected void onDestroy() { super.onDestroy(); mHandler.removeCallbacksAndMessages(null); }6.2 子线程中使用Handler在子线程中使用Handler需要手动创建Loopernew Thread(new Runnable() { Override public void run() { Looper.prepare(); // 初始化Looper Handler handler new Handler() { Override public void handleMessage(Message msg) { // 处理消息 } }; handler.sendEmptyMessage(0); Looper.loop(); // 启动消息循环 } }).start();6.3 HandlerThread的使用Android提供了HandlerThread类简化了子线程中Handler的使用HandlerThread thread new HandlerThread(MyHandlerThread); thread.start(); Handler handler new Handler(thread.getLooper()) { Override public void handleMessage(Message msg) { // 在子线程处理消息 } };七、总结Handler、Looper、MessageQueue构成的消息循环机制是Android系统的核心理解其工作原理对于开发高效、稳定的应用至关重要。本文从源码角度解析了三者的协作过程包括Looper的初始化与循环、MessageQueue的消息管理、Handler的消息发送与处理并介绍了实际开发中的应用场景和常见问题解决方案。通过深入理解Handler机制开发者可以更好地处理线程间通信、避免ANR、解决内存泄漏等问题提升应用性能和稳定性。更多关于Handler机制的详细内容可以参考Android官方文档及源码实现。【免费下载链接】InterviewQuestion项目地址: https://gitcode.com/gh_mirrors/in/InterviewQuestion创作声明：本文部分内容由AI辅助生成（AIGC），仅供参考