Android多線程之HandlerThread源碼解析

来源:https://www.cnblogs.com/leavesC/archive/2018/07/18/9333087.html
-Advertisement-
Play Games

想要瞭解 HandlerThread 的工作原理需要先對 Android 系統中以 Handler、Looper、MessageQueue 組成的非同步消息處理機制有所瞭解，如果你還沒有這方面的知識，可以先看我寫的另一篇文章： "Handler、Looper與MessageQueue源碼解析" 一、概 ...


想要瞭解 HandlerThread 的工作原理需要先對 Android 系統中以 Handler、Looper、MessageQueue 組成的非同步消息處理機制有所瞭解，如果你還沒有這方面的知識，可以先看我寫的另一篇文章：Handler、Looper與MessageQueue源碼解析

一、概述

先來瞭解下 HandlerThread 的幾個特性

  • HandlerThread 繼承於 Thread，本身就是一個線程類
  • HandlerThread 在內部維護了自己的 Looper 對象，所以可以進行 looper 迴圈
  • 創建 HandlerThread 後需要先調用 HandlerThread.start() 方法再向其下發任務，通過 run() 方法來創建 Looper 對象
  • 通過傳遞 HandlerThread 的 Looper 對象給 Handler 對象，從而可以通過 Handler 來向 HandlerThread 下發耗時任務

二、使用方式

再來看下 HandlerThread 的使用方式

創建 HandlerThread 並調用 start() 方法，使其在子線程內創建 Looper 對象

    HandlerThread handlerThread = new HandlerThread("HandlerThread");
    handlerThread.start();

然後以 HandlerThread 內部的 Looper 對象為參數創建一個 Handler，通過 Handler 向子線程發送 Message，以此下發耗時任務，消息的接收者與任務的處理者則由回調函數 ChildCallback 來完成

    Handler childThreadHandler = new Handler(handlerThread.getLooper(), new ChildCallback());
    
    //Callback 運行於子線程
    private class ChildCallback implements Handler.Callback {
        @Override
        public boolean handleMessage(Message msg) {
            //在此可以進行耗時操作
            //如果需要更新UI，則需要通過主線程的Handler來完成
            return false;
        }
    }

完整的示例代碼如下所示

public class MainActivity extends AppCompatActivity {

    private static final String TAG = "MainActivity";

    //Callback 運行於子線程
    private class ChildCallback implements Handler.Callback {
        @Override
        public boolean handleMessage(Message msg) {
            //在此可以進行耗時操作
            //如果需要更新UI，則需要通過主線程的Handler來完成
            Log.e(TAG, "ChildCallback 當前線程名：" + Thread.currentThread().getName() + "   " + "當前線程ID：" + Thread.currentThread().getId());
            Log.e(TAG, "耗時任務開始");
            try {
                Thread.sleep(5000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            Log.e(TAG, "耗時任務結束");
            //通知界面更新UI
            uiHandler.sendEmptyMessage(1);
            return false;
        }
    }

    //運行於主線程的Handler，用於更新UI
    @SuppressLint("HandlerLeak")
    private Handler uiHandler = new Handler() {
        @Override
        public void handleMessage(Message msg) {
            Log.e(TAG, "uiHandler 當前線程名：" + Thread.currentThread().getName() + "   " + "當前線程ID：" + Thread.currentThread().getId());
            Toast.makeText(MainActivity.this, "耗時操作完成", Toast.LENGTH_LONG).show();
        }
    };

    //用於向子線程發佈耗時任務的Handler
    private Handler childThreadHandler;

    private HandlerThread handlerThread;

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);
        handlerThread = new HandlerThread("HandlerThread");
        handlerThread.start();
        childThreadHandler = new Handler(handlerThread.getLooper(), new ChildCallback());
        Log.e(TAG, "onCreate 當前線程名：" + Thread.currentThread().getName() + "   " + "當前線程ID：" + Thread.currentThread().getId());
    }

    public void startTask(View view) {
        childThreadHandler.sendEmptyMessage(1);
    }

    @Override
    protected void onDestroy() {
        super.onDestroy();
        handlerThread.quit();
        childThreadHandler.removeCallbacksAndMessages(null);
    }

}

程式運行後的日誌如下所示，可以看出各個方法在調用時所處的線程

06-22 02:51:41.779 21977-21977/com.leavesc.myapplication E/MainActivity: onCreate 當前線程名：main   當前線程ID：2
06-22 02:51:44.927 21977-21995/com.leavesc.myapplication E/MainActivity: ChildCallback 當前線程名：HandlerThread   當前線程ID：497
06-22 02:51:44.928 21977-21995/com.leavesc.myapplication E/MainActivity: 耗時任務開始
06-22 02:51:49.930 21977-21995/com.leavesc.myapplication E/MainActivity: 耗時任務結束
06-22 02:51:49.930 21977-21977/com.leavesc.myapplication E/MainActivity: uiHandler 當前線程名：main   當前線程ID：2

三、源碼分析

先看下 HandlerThread 的類聲明

Thread 的子類

    public class HandlerThread extends Thread

兩個構造函數，可以傳入的參數分別是線程名和線程優先順序

    public HandlerThread(String name) {
        super(name);
        //使用預設的線程優先順序
        mPriority = Process.THREAD_PRIORITY_DEFAULT;
    }

    public HandlerThread(String name, int priority) {
        super(name);
        //使用自定義的線程優先順序
        mPriority = priority;
    }

看下其 run() 方法

    @Override
    public void run() {
        mTid = Process.myTid();
        //觸發當前線程創建 Looper 對象
        Looper.prepare();
        synchronized (this) {
            //獲取 Looper 對象
            mLooper = Looper.myLooper();
            //喚醒在等待的線程
            //喚醒 getLooer() 中可能還處於等待狀態的線程
            notifyAll();
        }
        //設置線程優先順序
        Process.setThreadPriority(mPriority);
        onLooperPrepared();
        //開啟消息迴圈
        Looper.loop();
        mTid = -1;
    }

Looper.prepare() 方法用於為當前線程創建一個 Looper 對象，在主線程需要依賴此 Looper 對象來構建一個 Handler 對象，通過該 Handler 對象來向子線程下發耗時任務（這些知識點可以在這裡瞭解：Handler、Looper與MessageQueue源碼解析）

之後可以看到有一個同步代碼塊，在當中調用了 notifyAll()來喚醒等待線程，那該喚醒的又是哪個線程呢？這裡需要明確各個方法是運行於哪個線程，run() 方法肯定是運行於子線程，但用於向 HandlerThread 下發任務的 Handler 是初始化於主線程，因此 getLooper()方法也是運行於主線程的。由於是兩個不同的線程，run() 方法和 getLooper() 的運行先後順序是不明確的，因此 getLooper() 方法需要確保 Looper 對象不為 null 時才返回，否則將一直阻塞等待 Looper 對象初始化完成

    //獲取與當前線程關聯的 Looper 對象
    //因為 getLooper() 方法可能先於 run() 被調用，此時就需要先等待 Looper 對象被創建
    public Looper getLooper() {
        //如果當前線程未在運行，則返回 null 
        if (!isAlive()) {
            return null;
        }
        synchronized (this) {
            //如果當前線程已處理運行狀態（已調用 start() 方法）且 Looper 對象還未創建
            //則調用 wait() 方法釋放鎖，等待 Looper 對象創建
            while (isAlive() && mLooper == null) {
                try {
                    wait();
                } catch (InterruptedException e) {
                }
            }
        }
        return mLooper;
    }

Looper 對象初始化完成後，就需要調用 Looper.loop() 來開啟消息迴圈，至此 HandlerThread 的初始化操作就完成了

最後再貼一下 HandlerThread 的完整源碼註釋

package android.os;

import android.annotation.NonNull;
import android.annotation.Nullable;

/**
 * Handy class for starting a new thread that has a looper. The looper can then be 
 * used to create handler classes. Note that start() must still be called.
 */
public class HandlerThread extends Thread {

    //線程優先順序
    int mPriority;

    //線程ID
    int mTid = -1;

    //當前線程持有的Looper對象
    Looper mLooper;

    //包含當前 Looper 對象的 Handler
    private @Nullable Handler mHandler;

    public HandlerThread(String name) {
        super(name);
        //使用預設的線程優先順序
        mPriority = Process.THREAD_PRIORITY_DEFAULT;
    }

    public HandlerThread(String name, int priority) {
        super(name);
        //使用自定義的線程優先順序
        mPriority = priority;
    }
    
    //在 Looper 迴圈啟動前調用
    //此處是空實現，留待子類重寫
    protected void onLooperPrepared() {
    }

    @Override
    public void run() {
        mTid = Process.myTid();
        //觸發當前線程創建 Looper 對象
        Looper.prepare();
        synchronized (this) {
            //獲取 Looper 對象
            mLooper = Looper.myLooper();
            //喚醒在等待的線程
            //喚醒 getLooer() 中可能還處於等待狀態的線程
            notifyAll();
        }
        //設置線程優先順序
        Process.setThreadPriority(mPriority);
        onLooperPrepared();
        //開啟消息迴圈
        Looper.loop();
        mTid = -1;
    }
    
    //獲取與當前線程關聯的 Looper 對象
    //因為 getLooper() 方法可能先於 run() 被調用，此時就需要先等待 Looper 對象被創建
    public Looper getLooper() {
        //如果當前線程未在運行，則返回 null 
        if (!isAlive()) {
            return null;
        }
        synchronized (this) {
            //如果當前線程已處理運行狀態（已調用 start() 方法）且 Looper 對象還未創建
            //則調用 wait() 方法釋放鎖，等待 Looper 對象創建
            while (isAlive() && mLooper == null) {
                try {
                    wait();
                } catch (InterruptedException e) {
                }
            }
        }
        return mLooper;
    }

    /**
     * @return a shared {@link Handler} associated with this thread
     * @hide
     */
    @NonNull
    public Handler getThreadHandler() {
        if (mHandler == null) {
            mHandler = new Handler(getLooper());
        }
        return mHandler;
    }

    //清空消息隊列中所有的消息
    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;
    }

    /**
     * Returns the identifier of this thread. See Process.myTid().
     */
    public int getThreadId() {
        return mTid;
    }

}

更多的源碼解讀請看這裡：Java_Android_Learn


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • MySQL中視圖
    轉載自：http://www.cnblogs.com/chenpi/p/5133648.html 什麼是視圖 通俗的講，視圖就是一條SELECT語句執行後返回的結果集。所以我們在創建視圖的時候，主要的工作就落在創建這條SQL查詢語句上。 視圖的特性 視圖是對若幹張基本表的引用，一張虛表，查詢語句執行 ...
  • sql server 時間格式轉換
    sql server2000中使用convert來取得datetime數據類型樣式（全） 日期數據格式的處理，兩個示例： CONVERT(varchar(16), 時間一, 20) 結果：2007-02-01 08:02/*時間一般為getdate()函數或數據表裡的欄位*/ CONVERT(var ...
  • sqlserver 使用游標過程中出現的錯誤
    下麵的見解是在使用游標的過程中做的日記。我也是第一次使用，如果有什麼不對的地方請批評指正，大家一起努力。 1. 消息 16951，級別 16，狀態 1，過程 usp_proc，第 16 行 變數 '@myref' 不能用作參數，因為在執行該過程前，不得為 CURSOR OUTPUT 參數分配游標。 ...
  • SQL Server 2012還原一直卡在ASYNC_IO_COMPLETION淺析
    在SQL Server 2012（11.0.7001.0）下麵在還原一個資料庫（備份文件40多G大小，實際資料庫大小300G），在還原過程中，出現一直等待ASYNC_IO_COMPLETION，如下測試截圖所示，已經等待了72分鐘了，但是還原比例依然為0% SELECT r.session_id ,... ...
  • hbase數據原理及基本架構
    第一：hbase介紹 hbase是一個構建在hdfs上的分散式列存儲系統； hbase是apache hadoop生態系統中的重要一員，主要用於海量結構化數據存儲 從邏輯上講，hbase將數據按照表、行和列進行存儲 1.大：一個表可以有數十億行，上百萬列； 2.無模式：每行都有一個可排序的主鍵和任意 ...
  • MySQL8.0新特性——支持原子DDL語句
    MySQL 8.0開始支持原子數據定義語言（DDL）語句。此功能稱為原子DDL。原子DDL語句將與DDL操作關聯的數據字典更新，存儲引擎操作和二進位日誌寫入組合到單個原子事務中。即使伺服器在操作期間暫停，也會提交事務，並將適用的更改保留到數據字典，存儲引擎和二進位日誌，或者回滾事務。 通過在MySQ ...
  • Android記憶體優化（四）LeakCanary使用詳解
    LeakCanary是檢測App記憶體泄露的工具, 記憶體泄露是Android開發中常見的問題, 使用程式的穩定性下降. LeakCanary 的機制如下： RefWatcher.watch() 會以監控對象來創建一個 KeyedWeakReference 弱引用對象 在 AndroidWatchExe ...
  • 簡單排序-選擇排序、直接插入排序、冒泡排序
    簡單排序（選擇排序、直接插入排序、冒泡排序）演算法都是n^2量級的比較（n是元素個數） 選擇排序動態圖： 直接插入排序動態圖： 冒泡排序動態圖： ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發（一）：使用.NET MAUI開發第一個安卓APP
    移動開發（一）：使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說，近來想嘗試開發一款安卓APP，考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP，畢竟是使用Visual Studio開發工具，使用起來也比較的順手，結合微軟官方的教程進行了安卓 ...
  • wpf ToggleButton選中效果和一個登錄界面
    前言 QuestPDF 是一個開源 .NET 庫，用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫，它徹底改變了我們生成 PDF 文檔的方 ...
  • 彈幕樹洞項目功能新增篇
    項目地址 項目後端地址： https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址： ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址： http://tree ...
  • 第27篇 sqlserver2022詳細安裝步驟
    話不多說，直接開乾 一.下載 1.官方鏈接下載： https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe，運行開始下載SQL server； 二. ...
  • .NET 開源高性能 MQTT 類庫
    前言 隨著物聯網（IoT）技術的迅猛發展，MQTT（消息隊列遙測傳輸）協議憑藉其輕量級和高效性，已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫，為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog文檔翻譯系列（六） - 可用的接收器、增強器、格式化輸出
    Serilog支持多種接收器用於日誌存儲，增強器用於添加屬性，LogContext管理動態屬性，支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項，適用於不同需求。 ...
  • 警惕 Visual Studio 屬性求值副作用導致邏輯不符合預期
    目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據，爬取信息時需要模擬瀏覽器行為，否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下： 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • [使用目前最新版]HybridCLR6.9.0+YooAsset2.2.4實現純C# Unity熱更新方案 (一)
    1.前言 什麼是熱更新 游戲或者軟體更新時，無需重新下載客戶端進行安裝，而是在應用程式啟動的情況下，在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR，Xlua，ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles，Addressable， ...
  • 在 ASP.NET Core Web API 中使用操作篩選器統一處理通用操作
    本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺，其實像阿裡雲，騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後，它會送 ...
  • 第28篇 如何.net中實現高效可靠數據同步api
    通過以下方式可以高效，並保證數據同步的可靠性 1.API設計 使用RESTful設計，確保API端點明確，並使用適當的HTTP方法（如POST用於創建，PUT用於更新）。 設計清晰的請求和響應模型，以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類