实例分析Android中HandlerThread线程用法
一、HandlerThread的介绍及使用举例
HandlerThread是什么鬼?其本质就是一个线程,但是HandlerThread在启动的时候会帮我们准备好一个Looper,并供外界使用,说白了就是使我们在子线程中更方便的使用Handler,比如没有HandlerThread我们要在子线程使用Handler,写法如下:
privateHandlermHandler;
@Override
publicvoidrun(){
super.run();
Looper.prepare();
mHandler=newHandler(){
@Override
publicvoidhandleMessage(Messagemsg){
}
};
Looper.loop();
}
有了HandlerThread就不用我们自己管理Looper了,至于为什么分析源码的时候就明白了。
HandlerThread使用简单介绍:
首先我们要初始化HandlerThread然后调用其start方法,也就是开启线程:
mHandlerThread=newHandlerThread("mHandlerThread");//这里的mHandlerThread其实就是线程的名字 mHandlerThread.start();
接下来初始化一个Handler并且将mHandlerThread中的Looper作为构造函数参数传递给Handler:
mHandler=newHandler(mHandlerThread.getLooper())
这样就保证了Hnadler运行在子线程。并且需要在适合的时机调用HandlerThread的quit方法或quitSafely方法,如Activity销毁的时候:
@Override protectedvoidonDestroy(){ // super.onDestroy(); //释放资源 mHandlerThread.quit(); }
quit()与quitSafely()方法比较(这里只说一些结论,源码可以自己查看):
相同点:
调用之后MessageQueue消息队列均不在接受新的消息加入队列。
不同点:
quit方法把MessageQueue消息池中所有的消息全部清空。quitSafely方法只会清空MessageQueue消息池中所有的延迟消息(延迟消息是指通过sendMessageDelayed或postDelayed等方法发送的消息),非延迟消息则不清除继续派发出去让Handler去处理。
接下来我们完整看一下HandlerThread例子源码:
publicclassMainActivityextendsActivity{
privateHandlerThreadmHandlerThread;
privateHandlermHandler;
privatebooleanflag;
//
@Override
protectedvoidonCreate(BundlesavedInstanceState){
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_main);
mHandlerThread=newHandlerThread("mHandlerThread");
mHandlerThread.start();
mHandler=newHandler(mHandlerThread.getLooper()){
@Override
publicvoidhandleMessage(Messagemsg){
//
try{
Thread.sleep(2000);
}catch(InterruptedExceptione){
e.printStackTrace();
}
if(flag){
Log.i("HandlerThread","更新:"+newRandom().nextInt(1000));
}
mHandler.sendEmptyMessage(1);
}
};
}
@Override
protectedvoidonResume(){
//
super.onResume();
flag=true;
mHandler.sendEmptyMessage(1);
}
@Override
protectedvoidonPause(){
//
super.onPause();
flag=false;
}
@Override
protectedvoidonDestroy(){
//
super.onDestroy();
//释放资源
mHandlerThread.quit();
}
}
运行程序就会在控制台看到每隔两秒有Log打出。至于HandlerThrea的使用就到此为止了,看懂上面小例子就差不多了。
二、HandlerThread的源码分析
HandlerThread源码非常简短,出去注释不到100行,这里就直接全部贴出来了:
publicclassHandlerThreadextendsThread{
intmPriority;
intmTid=-1;
LoopermLooper;
publicHandlerThread(Stringname){
super(name);
mPriority=Process.THREAD_PRIORITY_DEFAULT;
}
/**
*ConstructsaHandlerThread.
*@paramname
*@parampriorityTheprioritytorunthethreadat.Thevaluesuppliedmustbefrom
*{@linkandroid.os.Process}andnotfromjava.lang.Thread.
*/
publicHandlerThread(Stringname,intpriority){
super(name);
mPriority=priority;
}
/**
*Callbackmethodthatcanbeexplicitlyoverriddenifneededtoexecutesome
*setupbeforeLooperloops.
*/
protectedvoidonLooperPrepared(){
}
@Override
publicvoidrun(){
mTid=Process.myTid();
Looper.prepare();
synchronized(this){
mLooper=Looper.myLooper();
notifyAll();
}
Process.setThreadPriority(mPriority);
onLooperPrepared();
Looper.loop();
mTid=-1;
}
/**
*ThismethodreturnstheLooperassociatedwiththisthread.Ifthisthreadnotbeenstarted
*orforanyreasonisisAlive()returnsfalse,thismethodwillreturnnull.Ifthisthread
*hasbeenstarted,thismethodwillblockuntilthelooperhasbeeninitialized.
*@returnThelooper.
*/
publicLoopergetLooper(){
if(!isAlive()){
returnnull;
}
//Ifthethreadhasbeenstarted,waituntilthelooperhasbeencreated.
synchronized(this){
while(isAlive()&&mLooper==null){
try{
wait();
}catch(InterruptedExceptione){
}
}
}
returnmLooper;
}
publicbooleanquit(){
Looperlooper=getLooper();
if(looper!=null){
looper.quit();
returntrue;
}
returnfalse;
}
publicbooleanquitSafely(){
Looperlooper=getLooper();
if(looper!=null){
looper.quitSafely();
returntrue;
}
returnfalse;
}
/**
*Returnstheidentifierofthisthread.SeeProcess.myTid().
*/
publicintgetThreadId(){
returnmTid;
}
}
看第一行就知道了其本质就是一个线程。
6-9行以及17-20行构造函数,也很简单,就是初始化的时候我们可以定义线程名字,还可以传入线程优先级。
初始化完成,紧接着调用start()开发线程就会执行run方法逻辑。
30-41行代码,最重要的就是调用Looper.prepare()以及Looper.loop()方法为我们在子线程准备好一个Looper。并且用变量mLooper记录,调用getLooper()方法的时候返回。
但是,细心的你肯定发现run()方法中有个notifyAll(),getLooper()中有个wait()为什么要加这些鸟玩意?
大家发现没在HandlerThread例子中Handler的创建是在主线程完成的,创建的时候需要调用HandlerThread的getLooper()获取mLooper作为参数传递给Handler的构造函数,而Looper的创建是在子线程中创建的,这里就有线程同步问题了,比如我们调用getLooper()的时候HandlerThread中run()方法还没执行完,mLooper变量还未赋值,此时就执行了wait()等待逻辑,一直等到run()方法中mLooper被赋值,之后立即执行notifyAll(),然后getLooper()就可以正确返回mLooper了。
明白了吧,不明的话这里需要花些时间好好理解下,好了源码主要部分就分析完了,看到这里相信你对HandlerThread有了一定的了解了。
HandlerThread还是比较简单理解的,好了,本篇到此为止,希望对你有帮助。