HandlerThread解析

Posted 2020-09-10 丛林小阁楼

HandlerThread是一种具有消息循环的线程。HandlerThread可以接收消息并处理消息，并执行一些耗时操作，这样UI线程就可以把一些耗时的操作命令发送给HandlerThread，由该线程处理后再发送到主线程返回。这样主线程用于分发和显示，而子线程用于逻辑处理和运算。

HandlerThread使用的样例：

package com.fxb.handlerthead;

import android.app.Activity;
import android.os.Bundle;
import android.os.Handler;
import android.os.HandlerThread;
import android.os.Message;
import android.view.View;
import android.widget.Button;
import android.widget.TextView;

public class MainActivity extends Activity implements View.OnClickListener{

    private static final String TAG = "HandlerThreadTest";
    private static final int WHAT_CALUCULATE = 0x1001;
    private static final int WHAT_RESULT = 0x1002;

    private TextView tvShow;
    private Button btnStart;
    private HandlerThread handlerThread;
    private Handler mainHandler, subHandler;
    private int count;

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);
        initView();

        mainHandler = new Handler(){
            @Override
            public void handleMessage(Message msg) {
                super.handleMessage(msg);
            }
        };
        initThread();
    }

    private void initView(){
        tvShow = (TextView)findViewById(R.id.tvShow);
        btnStart = (Button)findViewById(R.id.btnStart);

        btnStart.setOnClickListener(this);
    }

    private void initThread(){
        handlerThread = new HandlerThread("myHandlerThread");
        handlerThread.start();

        subHandler = new Handler(handlerThread.getLooper()){
            @Override
            public void handleMessage(Message msg) {
                super.handleMessage(msg);
                if(msg.what == WHAT_CALUCULATE){
                    try {
                        Thread.sleep(500);
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }

                    final int num1 = msg.arg1;
                    final int num2 = msg.arg2;
                    final int result = num1 + num2;
                    mainHandler.post(new Runnable() {
                        @Override
                        public void run() {
                            tvShow.setText(num1+" + "+num2+" = "+result);
                        }
                    });
                }
            }
        };
    }


    @Override
    public void onClick(View v) {
        if(v == btnStart){
            mainHandler.postDelayed(new Runnable() {
                @Override
                public void run() {
                    count++;
                    Message msg = subHandler.obtainMessage(WHAT_CALUCULATE, count, count + 1);
                    msg.sendToTarget();

                    mainHandler.postDelayed(this, 1000);
                }
            }, 1000);
        }
    }
}

当点击Start按钮后，延时500ms后会在tvShow上显示1 + 2 = 3，1s后显示2 + 3 = 5，依次递增。

 

HandlerThread源码

import android.os.Looper;

public class HandlerThread extends Thread {
    int mPriority;
    int mTid = -1;
    Looper mLooper;

    public HandlerThread(String name) {
        super(name);
        mPriority = Process.THREAD_PRIORITY_DEFAULT;
    }

    public HandlerThread(String name, int priority) {
        super(name);
        mPriority = priority;
    }

    protected void onLooperPrepared() {
    }

    @Override
    public void run() {
        mTid = Process.myTid();
        Looper.prepare();
        synchronized (this) {
            mLooper = Looper.myLooper();
            notifyAll();
        }
        Process.setThreadPriority(mPriority);
        onLooperPrepared();
        Looper.loop();
        mTid = -1;
    }

    public Looper getLooper() {
        if (!isAlive()) {
            return null;
        }

        // If the thread has been started, wait until the looper has been created.
        synchronized (this) {
            while (isAlive() && mLooper == null) {
                try {
                    wait();
                } catch (InterruptedException e) {
                }
            }
        }
        return mLooper;
    }

    public boolean quit() {
        Looper looper = getLooper();
        if (looper != null) {
            looper.quit();
            return true;
        }
        return false;
    }

    public boolean quitSafely() {
        Looper looper = getLooper();
        if (looper != null) {
            looper.quitSafely();
            return true;
        }
        return false;
    }

    public int getThreadId() {
        return mTid;
    }
}

getLooper()时，如果没有创建好，则会阻塞，创建好后会唤醒，然后返回。