- 思维导图
- 概述
- 具体使用
- 源码分析
- 参考
HandlerThread 继承于 Thread,所以它本质就是个 Thread。与普通 Thread 的区别在于,它不仅建立了一个线程,并且创建了消息队列,有自己的 Looper,可以让我们在自己的线程中分发和处理消息,并对外提供自己的 Looper 的 get 方法。
HandlerThread 自带 Looper 使它可以通过消息队列来重复使用当前线程,节省系统资源开销。这是它的优点也是缺点,每个任务都将以队列的方式逐个被执行到,一旦队列中有某个任务执行时间过长,那么就会导致后续的任务都会被延迟处理。
publicclassHandlerThreadActivityextendsAppCompatActivity {
privateButtonmButton;
privateHandlerThreadmHandlerThread;
privateHandlermUiHandler;
privateHandlermChildHandler;
@OverrideprotectedvoidonCreate(@NullableBundlesavedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_handler);
initView();
mHandlerThread = newHandlerThread("HandlerThread");
mHandlerThread.start();
mUiHandler = newHandler(newHandler.Callback() {
@OverridepublicbooleanhandleMessage(Messagemsg) {
if (msg.what == 2) {
mButton.setText("子线程更新");
}
returnfalse;
}
});
mChildHandler = newHandler(mHandlerThread.getLooper(), newHandler.Callback() {
@OverridepublicbooleanhandleMessage(Messagemsg) {
if (msg.what == 1) {
try {
//子线程模拟延迟处理Thread.sleep(2000);
mUiHandler.sendEmptyMessage(2);
} catch (InterruptedExceptione) {
e.printStackTrace();
}
}
returnfalse;
}
});
}
publicvoidinitView() {
mButton = findViewById(R.id.btn_show);
mButton.setOnClickListener(newView.OnClickListener() {
@OverridepublicvoidonClick(Viewv) {
mChildHandler.sendEmptyMessage(1);
}
});
}
}publicclassHandlerThreadextendsThread {
intmPriority;
intmTid = -1;
LoopermLooper;
private@NullableHandlermHandler;
publicHandlerThread(Stringname) {
super(name);
mPriority = Process.THREAD_PRIORITY_DEFAULT;
}
publicHandlerThread(Stringname, intpriority) {
super(name);
mPriority = priority;
}
protectedvoidonLooperPrepared() {
}
@Overridepublicvoidrun() {
mTid = Process.myTid();
Looper.prepare();
synchronized (this) {
mLooper = Looper.myLooper();
// 通知取 Looper 的线程,此时 Looper 已经创建好了notifyAll();
}
Process.setThreadPriority(mPriority);
onLooperPrepared();
Looper.loop();
mTid = -1;
}
publicLoopergetLooper() {
if (!isAlive()) {
returnnull;
}
synchronized (this) {
while (isAlive() && mLooper == null) {
try {
// 如果新线程还未创建 Looper,则等待wait();
} catch (InterruptedExceptione) {
}
}
}
returnmLooper;
}
@NonNullpublicHandlergetThreadHandler() {
if (mHandler == null) {
mHandler = newHandler(getLooper());
}
returnmHandler;
}
publicbooleanquit() {
Looperlooper = getLooper();
if (looper != null) {
looper.quit();
returntrue;
}
returnfalse;
}
publicbooleanquitSafely() {
Looperlooper = getLooper();
if (looper != null) {
looper.quitSafely();
returntrue;
}
returnfalse;
}
publicintgetThreadId() {
returnmTid;
}
}源码很简单,就是在 run 方法中执行 Looper.prepare()、Looper.loop() 构造消息循环系统。外界可以通过 getLooper() 这个方法拿到这个 Looper。
总结为下:
- HandlerThread 是一个自带 Looper 的线程,因此只能作为子线程使用
- HandlerThread 必须配合 Handler 使用,HandlerThread 线程中具体做什么事,需要在 Handler 的 callback 中进行,因为它自己的 run 方法被写死了
- 子线程的 Handler 与 HandlerThread 关系建立是通过构造子线程的Handler 传入 HandlerThread 的 Looper 。所以在此之前,必须先调用 mHandlerThread.start 让 run 方法跑起来 Looper 才能创建。