HandlerThread基于事务对列的实现探索

立即下载用AI写一个

发布时间：2019-06-22

0人 | 浏览：813次 | 收藏 |

技术：android

运行环境：androidstudio

概述

在android开发过程中，我们经常用到Thread，Runnable，但是有一个特别的线程HandlerThread却是我很少用到的，那么今天就来讲讲HandlerThread的使用。

详细

###前言
在android开发过程中，我们经常用到Thread，Runnable，但是有一个特别的线程HandlerThread却是我很少用到的，那么今天就来讲讲HandlerThread的使用。

今天涉及的内容：
1. HandlerThread相比Thread的优势
2. HandlerThread实现事务队列探索
3. 事务队列处理类TaskThread缺陷及适用场景
4. 项目结构图

先上波效果图:
![](/contentImages/image/20190622/qB2VqffPl1loKjRwfIp.gif)

####一. HandlerThread相比Thread的优势
 HandlerThread的源码中有这么一行:
```
public class HandlerThread extends Thread {
//此处省略
//.....
}
```
即意味着HandlerThread其实也是一个Thread，但它又不仅仅是一个一般的Thread，其特别之处在于源码中的一段代码：
```
    @Override
    public void run() {
        mTid = Process.myTid();
        Looper.prepare();
        synchronized (this) {
            mLooper = Looper.myLooper();
            notifyAll();
        }
        Process.setThreadPriority(mPriority);
        onLooperPrepared();
        Looper.loop();
        mTid = -1;
    }
```
正是这段代码给HandlerThread带来了不同之处，那么HandlerThread有什么特点呢：
1. HandlerThread是一个维护有自己的一套Looper对列的Thread
2. HandlerThread拥有自己的Handler
简单的来说就是HandlerThread是一个拥有自己维护队列haosh，可执行串行耗时操作的Thread
3. 需要注意的是 HandlerThread 的Handler不能直接操作UI
####二.HandlerThread实现事务队列探索
#####2.1 HandlerThread的基本使用
在讲HandlerThread实现事务队列前，我们需要了解HandlerThread的基本用法
```
        //新建HandlerThread
        HandlerThread thread=new HandlerThread("k");
        //HandlerThread执行
        thread.start();
        //获取HandlerThread的Handler并接收消息
        final Handler handler=new Handler(thread.getLooper(), new Handler.Callback() {
            @Override
            public boolean handleMessage(Message msg) {
                Log.i("pei","======msg pppp====="+msg.what);
                return false;
            }
        });
        //handler启动新线程
        handler.post(new Runnable() {
            @Override
            public void run() {
                //handler发送消息
                handler.sendEmptyMessage(23);
            }
        });
```
#####2.2 事务队列TaskThread的基本使用
鉴于HandlerThread有一个自动维护的串行队列，我想到是否可以利用这点实现一个事务队列，于是自己发封装了一个事务队列的类TaskThread，其基本使用如下：
初始化：
```
        mTaskThread=new TaskThread("a");
        mTaskThread.start();
```
发送事件：
```
       mTaskThread.addAffair(Object obj);
```
回调监听：
```
        mTaskThread.setOnAffairListener(new TaskThread.OnAffairListener() {
            @Override
            public void doAffair(int taskId, Object result) {
                final String kk=result.toString()+taskId;
                Log.i("pei","=====kk==1==="+kk);

runOnUiThread(new Runnable() {
                    @Override
                    public void run() {
                        mTextView.setText(kk);
                    }
                });
            }
        });
```
销毁：
```
  if(mTaskThread!=null) {
            mTaskThread.quit();
   }
```
#####2.3 TaskThread在MainActivity中使用代码样例

```
package com.webservicedemo;

import androidx.appcompat.app.AppCompatActivity;

import android.os.Bundle;
import android.util.Log;
import android.view.View;
import android.widget.Button;
import android.widget.TextView;

public class MainActivity extends AppCompatActivity {

private Button mButton;
    private TextView mTextView;

private TaskThread mTaskThread;

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

initView();
        initData();
        setListener();
    }

private void initView(){
        mTextView = findViewById(R.id.textView);
        mButton = findViewById(R.id.button);
    }

private void initData(){
        mTaskThread=new TaskThread("a");
        mTaskThread.start();
    }

private void setListener(){
        mTaskThread.setOnAffairListener(new TaskThread.OnAffairListener() {
            @Override
            public void doAffair(int taskId, Object result) {
                final String kk=result.toString()+taskId;
                Log.i("pei","=====kk==1==="+kk);

runOnUiThread(new Runnable() {
                    @Override
                    public void run() {
                        mTextView.setText(kk);
                    }
                });
            }
        });

mButton.setOnClickListener(new View.OnClickListener() {
            @Override
            public void onClick(View v) {
                Log.i("pei","=====ggg=====");
                mTaskThread.addAffair("kf");
            }
        });

}

@Override
    protected void onDestroy(){
        if(mTaskThread!=null) {
            mTaskThread.quit();
        }
        super.onDestroy();
    }
}
```
实现效果如下：
![](/contentImages/image/20190622/EZcu4aem3ABDd5bMZVI.gif)
####三.事务队列处理类TaskThread缺陷及适用场景
#####3.1 TaskThread使用缺陷
由于TaskThread继承自HandlerThread，在使用过程中有一个重要问题，当然也是使用HandlerThread需要注意的问题，那就是TaskThread的Handler不能接触UI操作，由于TaskThread的队列由Looper来维护，所以当TaskThread串行处理事务的时候，不会等第一个处理完再处理第二个，而是当第一个移出looper队列后会直接移第二个中间不会有时间间隔。当TaskThread执行for循环添加事务的时候，类似下面这样添加：
```
for (int i = 0; i <10 ; i++) {
      mTaskThread.addAffair("kf");
 }
```
然后用 runOnUiThread去更新ui的时候，只能更新最后一个ui，即ui中只会显示i=9时的结果。
综上所述，TaskThread对列处理拥有以下缺陷：
1. TaskThread的Handler不能接触UI操作
2. TaskThread事务间处理没有时间间隔
3. for循环添加事务的时候，只能更新最后一个ui的结果
#####3.2 TaskThread适用场景
基于以上分析，TaskThread适合不接触UI更新，不需要关注每个事务处理结果的情况，所以他比较适合在后台进行多文件下载的情况。
####四.项目结构图

![](/contentImages/image/20190622/cDcRr7gktPGTQFKE3rX.png)

本实例支付的费用只是购买源码的费用，如有疑问欢迎在文末留言交流，如需作者在线代码指导、定制等，在作者开启付费服务后，可以点击“购买服务”进行实时联系，请知悉，谢谢

感谢

手机上随时阅读、收藏该文章？请扫下方二维码

HandlerThread基于事务对列的实现探索

概述

详细

相似例子推荐

评论

作者

评分详细

作者例子