HandlerThread原理分析、实战、最佳实践!

HandlerThread原理分析、实战、最佳实践!本文我们将学习HandlerThread的实现原理,以及开发时,如何正确的使用它来实现我们的开发任务。HandlerThread源码分析设想这样一个场景:我们要在一个线程A中处理业务逻辑,在另一个线程B中,监听A的执行,并进行结果处理。这时我们使用HandlerThread就可以非常简单的实现该功能了。通常我们的线程交互场景,都是UI线程中启动子线程,并且由子线程完成工作任务,最终结果交给UI线程。现在我们的使用场景是,在子线程中监控其他线程的执行结果(这里的其他线程可以是另一个子线程,也可以是UI

本文我们将学习HandlerThread的实现原理,以及开发时,如何正确的使用它来实现我们的开发任务。

HandlerThread源码分析


设想这样一个场景:我们要在一个线程A中处理业务逻辑,在另一个线程B中,监听A的执行,并进行结果处理。这时我们使用HandlerThread就可以非常简单的实现该功能了。

通常我们的线程交互场景,都是UI线程中启动子线程,并且由子线程完成工作任务,最终结果交给UI线程。现在我们的使用场景是,在子线程中监控其他线程的执行结果(这里的其他线程可以是另一个子线程,也可以是UI线程),并在子线程中进行结果的处理。

通过描述,我们可以得出2点结论:第一,这个过程中,需要存在2个线程;第二,这两个线程需要进行数据传输(交互)。那么,我们很自然的就想到了Handler机制来实现该功能,但是我们自己在一个子线程中,使用Handler稍显麻烦一些,HandlerThread内置了Handler,简化了我们的操作。

HandlerThread构造函数和继承关系:

public class HandlerThread extends Thread {
    int mPriority;
    int mTid = -1;
    Looper mLooper;
    private @Nullable Handler mHandler;

    public HandlerThread(String name) {//构造函数1
        super(name);
        mPriority = Process.THREAD_PRIORITY_DEFAULT;
    }
    
    /**
     * Constructs a HandlerThread.
     * @param name
     * @param priority The priority to run the thread at. The value supplied must be from 
     * {@link android.os.Process} and not from java.lang.Thread.
     */
    public HandlerThread(String name, int priority) {//构造函数2
        super(name);
        mPriority = priority;
    }
}
逻辑解析:
  1. HandlerThread继承自Thread类,所以它本质上是一个线程类,可以实现线程相关的操作。
  2. 我们来看HandlerThread的构造函数,这里有2个重载版本。
  3. 第一个构造函数接收一个name参数,直接调用了super方法,为该线程命令,且线程优先级为Process.THREAD_PRIORITY_DEFAULT。
  4. 第二个构造函数接收2个参数,可实现线程命名,和设置线程的优先级。

HandlerThread的run方法:

    @Override
    public void run() {
        mTid = Process.myTid();
        Looper.prepare();
        synchronized (this) {
            mLooper = Looper.myLooper();
            notifyAll();
        }
        Process.setThreadPriority(mPriority);
        onLooperPrepared();
        Looper.loop();
        mTid = -1;
    }
逻辑解析:
  1. 我们在创建了HandlerThread实例之后,调用start()方法执行,ART虚拟机会帮我们创建一个线程对象,然后在子线程中执行run方法。
  2. run方法中,执行了Looper.prepare()方法,创建了一个Looper对象并绑定到该线程。
  3. 然后在同步块中,执行了mLooper的赋值,调用notifyAll通知Looper已创建完成。
  4. 调用Process.setThreadPriority方法设置线程优先级。
  5. 调用空方法onLooperPrepared,通常用于回调使用。
  6. 最后调用Looper.loop()方法,启动该线程的消息循环。

getLooper方法:

    public Looper getLooper() {
        if (!isAlive()) {//判断线程是否存活
            return null;
        }
        
        // If the thread has been started, wait until the looper has been created.
        synchronized (this) {
            //如果线程存活,但mLooper没有创建完成,则等待
            while (isAlive() && mLooper == null) {
                try {
                    wait();
                } catch (InterruptedException e) {
                }
            }
        }
        return mLooper;//返回当前线程的Looper对象
    }
逻辑解析:
  1. getLooper方法可以返回当前线程绑定的Looper对象,我们可以使用该对象作为参数,创建一个该线程的Handler对象,用于线程交互。
  2. getLooper方法首先会判断当前线程是否存活,如果存活,则继续。
  3. 如果线程存活,但Looper对象还没有创建完成,则调用wait方法进行等待(Looper创建完成后,会在HandlerThread的run方法中,调用notifyAll()通知,以继续执行当前逻辑)。
  4. 最后返回Looper对象即可。

HandlerThread的getThreadHandler方法

    /**
     * @return a shared {@link Handler} associated with this thread
     * @hide
     */
    public Handler getThreadHandler() {
        if (mHandler == null) {
            mHandler = new Handler(getLooper());
        }
        return mHandler;
    }
  1. 如果我们不想自己创建Handler对象,也可以使用HandlerThread为他们提供的Handler对象。
  2. getThreadHandler方法返回一个当前线程的Handler对象。
  3. 它是一个隐藏方法,我们在应用中不可调用。

HandlerThread的退出

    //立即执行退出
    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;
    }

当不需要HandlerThread时,需要调用quit方法或quitSafely方法结束线程管理的Looper消息循环。

HandlerThread实战


HandlerThread的实现其实并不复杂,我们以一个简单Demo来看它的使用。

Demo

public class HandlerThreadTest {
    private final static String TAG = "budaye";
    public static final int HT_MSG = 1;
    private HandlerThread mHandlerThread = new HandlerThread("myHandlerThread", Process.THREAD_PRIORITY_BACKGROUND);
    private Handler mHandler = null;

    public void startHandlerthread(){
        mHandlerThread.start();
        if (mHandler == null){
            mHandler = new Handler(mHandlerThread.getLooper()){
                @Override
                public void handleMessage(@NonNull Message msg) {
                    super.handleMessage(msg);
                    switch (msg.what){
                        case HT_MSG:
                            Log.d(TAG, "当前线程:" + Thread.currentThread());
                            Log.d(TAG, "收到其他线程发送过来的消息了");
                            break;
                    }
                }
            };
        }
    }
    public void sendMessage() {
        Log.d(TAG, "当前线程:" + Thread.currentThread());
        Message msg = Message.obtain();
        msg.what = HT_MSG;
        mHandler.sendMessage(msg);
    }
}
逻辑解析:
  1. 在HandlerThreadTest里,创建了一个HandlerThread对象。
  2. 调用startHandlerthread方法,开始了HandlerThread对象的线程消息循环,并且创建了一个mHandler对象,用于处理其他线程发送过来的消息。
  3. 我们可以在UI线程中调用sendMessage方法来发送给HandlerThread线程一个消息,并在mHandler对象的handleMessage方法中进行处理。

Demo日志输出

25208-25208/com.example.simpledemo D/budaye: 当前线程:Thread[main,5,main]
25208-25284/com.example.simpledemo D/budaye: 当前线程:Thread[myHandlerThread,5,main]
25208-25284/com.example.simpledemo D/budaye: 收到其他线程发送过来的消息了

我们分别在2个线程中输出了日志。

最佳实践&总结


  1. HandlerThread是一个异步处理的工具类,它可以帮助我们很轻松的实现异步线程处理。
  2. HandlerThread继承自Thread类,它的本质是一个线程类。
  3. HandlerThread实现原理非常简单,它利用了Handler原理,在内部了一个Looper循环,并绑定到当前线程中。
  4. 我们使用创建一个Handler对象,绑定到HandlerTHread对象所对应的Looper,并处理其他线程发送过来的消息。
  5. HandlerThread在构造方法中可以设置线程优先级,默认使用Process.THREAD_PRIORITY_DEFAULT作为默认优先级。
  6. 我们在应用过程中,不要大量使用HandlerThread来执行异步任务,这样会造成线程资源的浪费,大量的异步任务,建议使用线程池来进行操作。
  7. HandlerThread的线程优先级设定一定要注意,如果任务优先级不高,则应该设置成后台任务优先级,避免和UI线程抢占系统资源。
版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

发布者:全栈程序员-站长,转载请注明出处:https://javaforall.net/215481.html原文链接:https://javaforall.net

赞 (0)
全栈程序员-站长的头像全栈程序员-站长

相关推荐

  • CSS自定义鼠标样式[通俗易懂]

    CSS自定义鼠标样式[通俗易懂]效果图原理cursor属性:cursor属性规定要显示的光标的类型(形状)。该属性定义了鼠标指针放在一个元素边界范围内时所用的光标形状。使用url,可自定义鼠标图标。cursor:url(‘https://blog-static.cnblogs.com/files/lucas–liu/cat6.ico’),default;自定义图标注意点尺寸最好选择不大于于32*32像素的Opera9.3和Safari3不支持url值图片最好用绝对路径浏览器兼容性不一

    2022年5月31日
  • 单点登录原理与简单实现(单点登录原理与简单实现)

    单点登录(SingleSignOn),简称为SSO,是目前比较流行的企业业务整合的解决方案之一。SSO的定义是在多个应用系统中,用户只需要登录一次就可以访问所有相互信任的应用系统。以下是个人查询资料的借鉴及对接某大型互联网公司单点系统后的一个总结和理解一、首先了解下单系统登录机制1、http无状态协议  web应用采用browser/server架构,http作为通信协议。http是无状态协…

    2022年4月11日
  • 深圳有哪些不错的互联网公司_深圳好公司推荐

    深圳有哪些不错的互联网公司_深圳好公司推荐深圳作为一个一线城市,改革开放已经40余年了,即使如此,栈长觉得深圳现在也还是一个非常年轻的城市,不断吸引着大批外省务工人员。深圳不仅是一个包容度很高的城市,也是一个互联网公司扎堆的城市,今天栈

    2022年8月6日
  • python闭包详解_python闭包的使用场景

    python闭包详解_python闭包的使用场景闭包首先了解一下:如果在一个函数的内部定义了另一个函数,外部的我们叫他外函数,内部的我们叫他内函数。在一个外函数中定义了一个内函数,内函数里运用了外函数的临时变量,并且外函数的返回值是内函数的引用

    2022年7月29日
  • 报关员计算机知识,报关员的计算机水平要多少[通俗易懂]

    报关员计算机知识,报关员的计算机水平要多少[通俗易懂]baijuantie新兵答主12-12TA获得超过3110个赞什么是报关员报关员(Customsbroker)又称企业海关经纪人、企业报关人员。报关员是指代表所属企业/单位向海关办理进出口货物报关纳税、在海关备案登记等通关手续的人员。报关员不是自由职业者,只能受雇于一个依法向海关注册登记的进出口货物收发货人或者企业,并代表该企业向海关办理业务。报关员的主要工作内容1.按照海关及规定要求在报关期限…

    2022年9月21日
  • OpenCV学习之路–5–OpenCV3.4.10的ARM版本移植到开发板

    OpenCV学习之路–5–OpenCV3.4.10的ARM版本移植到开发板开发板:迅为IMX6Q移植QTE5.7编译好的ARM版本OpenCV3.4.10文件:OpenCV3.4.10ARM版编译好的OpenCV依赖库文件:1.将/usr/local/arm/opencv-arm/lib/下的库拷贝到开发板相同目录及/lib/下mkdir/home/topeet/iMX6Q/qt/usr/local/arm/opencv-armcd/usr/local/arm/opencv-arm/cp-r*/home/topeet/iM…

    2022年10月14日

发表回复

您的邮箱地址不会被公开。 必填项已用 * 标注

关注全栈程序员社区公众号