1. HandlerThread的本质
- 通过继承
Thread
类,创建一个带有Looper
对象的新工作线程,不需要手动调用Looper.prepare()
和Looper.loop()
方法- 通过封装
Handler
类,快速创建handler并与其他线程进行交互
我们首先将简单介绍Handler
,然后应用Handler+Thread
来实现多线程通信,最后讲解如何通过HandlerThread
来实现多线程通信。
2. Handler
用于线程之间的通信,如将工作线程中需要更新UI的信息传递到主线程,从而实现
“工作线程对UI的更新”
在这个过程中用到的组件有:Handler
,Looper
,MessageQueue
,Message
-
Looper
: 消息队列和Handler的通信媒介,进行消息循环- 消息获取:循环取出消息队列中的消息
-
消息分发:将消息分发给对应的
Handler
,遵循“谁发送,谁处理”
的原则
-
MessageQueue
:- 一种数据结构,存储
Handler
发送过来的消息
- 一种数据结构,存储
-
Message
: 需要在某一线程执行的操作信息-
obj
为其携带的传递对象 -
what
为消息标识
-
-
整体流程:
-
Handler
发送Msg
,这个消息被存储在该线程的MessageQueue
,Looper
不断循环取出消息队列中的Msg
,并分发给对应的Handler
进行处理。
-
- 一个线程会配备一个
Looper
,一个MessageQueue
, 但是可以拥有无数个Handler
。 - 主线程中的
Looper
已经帮我们配置好了,所以我们并不需要自己实现Looper
的相关操作,但是在其他线程如果想要使用Looper
,需要自己进行配置。 -
Handler
会与线程进行绑定,一个Handler
只能与一个线程绑定(为这个线程发送和处理消息),但是一个线程可以与多个Handler
进行绑定
3. Handler + Thread 实现线程
3.1 sendMessage + handleMessage
- 在新建子线程中执行耗时操作,并新建Message对象sendMessage
object: Thread(){
override fun run() {
try {
sleep(6000)
addDataToServiceList()
}catch (e: InterruptedException) {
e.printStackTrace()
}
val msg = Message.obtain()
msg.what = 1
handler.sendMessage(msg)
}
}.start()
- 在主线程中创建Handler对象,并handleMessage,根据Message的what属性来确定操作
handler = object :Handler(){
override fun handleMessage(msg: Message) {
when(msg.what){
1-> setRecyclerView(mRecyclerView)
}
}
}
3.2 post
- 新建子线程,在执行完try catch之后
- 执行handler.post,在其中Runnable的run方法中执行得到数据后的操作
handler = Handler()
object: Thread(){
override fun run() {
try {
sleep(6000)
addDataToServiceList()
}catch (e: InterruptedException) {
e.printStackTrace()
}
handler.post(Runnable {
setRecyclerView(mRecyclerView)
})
}
}.start()
4. HandlerThread
4.1 工作原理
- 通过继承
Looper
类,创建一个带有Looper
对象的新工作线程 - 通过封装
Handler
类,快速创建handler
并与其他线程进行交互
4.2 实现步骤
- 创建
HandlerThread
实例对象:需要传入一个线程名字的参数,用来标记该线程 - 因为
HandlerThread
继承了Thread
类,所以直接HandlerThread.start()
就可以启动一个线程 - 创建
Handler
并实现handleMessage
方法 - 用
handler
发送消息 - 结束线程:
HandlerThread.quit()
// 步骤1:创建HandlerThread实例对象
// 传入参数 = 线程名字,作用 = 标记该线程
HandlerThread mHandlerThread = new HandlerThread("handlerThread");
// 步骤2:启动线程
mHandlerThread.start();
// 步骤3:创建工作线程Handler & 复写handleMessage()
// 作用:关联HandlerThread的Looper对象、实现消息处理操作 & 与其他线程进行通信
// 注:消息处理操作(HandlerMessage())的执行线程 = mHandlerThread所创建的工作线程中执行
Handler workHandler = new Handler( mHandlerThread.getLooper() ) {
@Override
public boolean handleMessage(Message msg) {
...//消息处理
return true;
}
});
// 步骤4:使用工作线程Handler向工作线程的消息队列发送消息
// 在工作线程中,当消息循环时取出对应消息 & 在工作线程执行相关操作
// a. 定义要发送的消息
Message msg = Message.obtain();
msg.what = 2; //消息的标识
msg.obj = "B"; // 消息的存放
// b. 通过Handler发送消息到其绑定的消息队列
workHandler.sendMessage(msg);
// 步骤5:结束线程,即停止线程的消息循环
mHandlerThread.quit();
5. 参考文档
https://www.jianshu.com/p/9c10beaa1c95
https://www.jianshu.com/p/e172a2d58905
https://www.raywenderlich.com/5466-threading-with-handlerthread-in-android
https://blog.csdn.net/fdsafwagdagadg6576/article/details/110293636