Handler消息机制

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

一句话，每个线程可以创建一个 Looper ，每个 Looper 轮询着一个 MessageQueue 不断取出消息，有消息则回调给 Handler，Handler 负责向 MessageQueue 中发送消息和处理回调的消息来完成线程之间的转换。

也就是说与我们交互的是handler，我们使用handler向looper发送消息，looper就在他所在的线程对消息进行处理了

那么runnable呢，runnable就是一段让looper直接执行的指令，而不是通过message判断该执行什么已经设定好的操作

import android.os.*
import android.util.Log
import java.util.concurrent.atomic.AtomicBooleanclass HandlerExample {// 日志标签private val TAG = "HandlerExample"// 消息类型常量companion object {const val MSG_HELLO = 1const val MSG_WORLD = 2const val MSG_STOP = 3}// 工作线程和对应的 Handlerprivate lateinit var workerThread: WorkerThreadprivate lateinit var workerHandler: Handler// UI 线程的 Handlerprivate val mainHandler = object : Handler(Looper.getMainLooper()) {override fun handleMessage(msg: Message) {when (msg.what) {MSG_HELLO -> Log.d(TAG, "Main Thread received: Hello")MSG_WORLD -> Log.d(TAG, "Main Thread received: World")else -> super.handleMessage(msg)}}}// 工作线程类inner class WorkerThread : Thread() {private val running = AtomicBoolean(false)override fun run() {Log.d(TAG, "Worker thread started")// 为当前线程创建 LooperLooper.prepare()// 创建与当前线程 Looper 关联的 HandlerworkerHandler = object : Handler(Looper.myLooper()!!) {override fun handleMessage(msg: Message) {when (msg.what) {MSG_HELLO -> {Log.d(TAG, "Worker thread received: Hello")// 模拟耗时操作Thread.sleep(1000)// 向主线程发送消息mainHandler.sendEmptyMessage(MSG_HELLO)}MSG_WORLD -> {Log.d(TAG, "Worker thread received: World")// 模拟耗时操作Thread.sleep(1000)// 向主线程发送消息mainHandler.sendEmptyMessage(MSG_WORLD)}MSG_STOP -> {Log.d(TAG, "Worker thread received: Stop")running.set(false)Looper.myLooper()?.quit()}}}}running.set(true)// 启动消息循环Looper.loop()Log.d(TAG, "Worker thread finished")}fun isRunning(): Boolean = running.get()}// 启动工作线程fun startWorker() {workerThread = WorkerThread()workerThread.start()// 等待线程启动并初始化 Looperwhile (!this::workerHandler.isInitialized) {Thread.sleep(10)}// 发送消息到工作线程workerHandler.sendEmptyMessage(MSG_HELLO)workerHandler.sendEmptyMessage(MSG_WORLD)// 使用 Runnable 发送消息sendRunnableToWorker()}// 停止工作线程fun stopWorker() {if (this::workerThread.isInitialized && workerThread.isRunning()) {workerHandler.sendEmptyMessage(MSG_STOP)try {workerThread.join()} catch (e: InterruptedException) {e.printStackTrace()}}}// 测试方法fun testHandler() {Log.d(TAG, "Starting handler test")// 启动工作线程startWorker()// 等待工作完成try {Thread.sleep(3000)} catch (e: InterruptedException) {e.printStackTrace()}// 停止工作线程stopWorker()Log.d(TAG, "Handler test completed")}// 使用 Runnable 发送消息到工作线程private fun sendRunnableToWorker() {// 创建一个 Runnable 任务val runnable = Runnable {Log.d(TAG, "Worker thread is executing Runnable")// 模拟耗时操作try {Thread.sleep(1500)} catch (e: InterruptedException) {e.printStackTrace()}// 向主线程发送消息mainHandler.post {Log.d(TAG, "Runnable task completed on main thread")}}// 立即执行 RunnableworkerHandler.post(runnable)// 延迟执行 RunnableworkerHandler.postDelayed({Log.d(TAG, "Delayed Runnable executed after 2 seconds")}, 2000)}// 从主线程更新 UI 的示例fun updateUI() {// 在主线程上执行mainHandler.post {// 这里可以安全地更新 UILog.d(TAG, "Updating UI on main thread")}}
}