Android 自定义线程管理器（串行）

本管理器优点：
1.单页面来说，handlerThread作为主要管理方式，一个线程复用，对性能影响小
2.简化代码，一句代码即可开启一个异步任务，一句代码把异步结果传给UI线程
本管理器缺点：
1.由于单线程串行处理任务，有阻塞情况会影响其他任务。
2.每个activity一个管理器（一个线程），当连续开启多个activity的时候，同样对性能影响较大，有OOM风险。

以前写项目的时候，都是直接new Thread（）来创建线程，这样写项目后期非常不利于维护，然后考虑是否能写一个类专门用来管理线程呢？

首先我们需要创建一个线程：

private HandlerThread mHandlerThread;
public void oncreate() {
    this.mHandlerThread = 
         new HandlerThread("activity worker:" + this.getClass().getSimpleName());
    this.mHandlerThread.start();
}

第二我们线程管理器只是管理线程，不进行具体的逻辑操作，那么就用到了Handler机制：

先创建一个UiHandler：

private static class UiHandler extends Handler {
    private  HandlerManager manager;
    public UiHandler(HandlerManager manager) {
        this.manager = manager;
    }

    public void handleMessage(Message msg) {
        super.handleMessage(msg);
        if(manager  != null) {
            //调用处理业务代码
        }
    }
}

由于Handler为静态内部类，与外部类并无直接联系，这样处理容易产生内存泄漏，manager对象无法释放，那么就要介入弱引用来处理该代码（也可以用软引用）：

private static class UiHandler extends Handler {
    private  WeakReference<HandlerManager> mActivityReference;
    public UiHandler(HandlerManager manager) {
        this.mActivityReference = new WeakReference(manager);
    }

    public void handleMessage(Message msg) {
        super.handleMessage(msg);
        //调用处理业务代码
        }

    }
}

同理还有创建一个异步线程BackgroundHandler，需要注意的是创建该Handler需要把新创建的线程looper传递过去：

private static class BackgroundHandler extends Handler {
    private  WeakReference<HandlerManager> mActivityReference;
    BackgroundHandler(HandlerManager manager, Looper looper) {
        super(looper);
        this.mActivityReference = new WeakReference(manager);
    }
    //发送消息
    public void handleMessage(Message msg) {
        super.handleMessage(msg);
        //调用处理业务代码
        }

    }
}

这两个Handler我们需要在线程创建的时候就创建，所以OnCreate方法要这样改：

public void oncreate() {
    this.mHandlerThread = new HandlerThread("activity worker:" + this.getClass().getSimpleName());
    this.mHandlerThread.start();
    this.mBackgroundHandler 
            = new BackgroundHandler(this, this.mHandlerThread.getLooper());
    this.mUiHandler = new UiHandler(this);
}

第三我们就要发送消息了，先理清逻辑：

1.通过消息通知Manager有异步请求。
2.Manager给BackgroundHandler发消息让他处理异步逻辑。
3.BackgroundHandler处理异步逻辑，并把处理结果返回给Manager。
4.Manager拿到处理结果发消息给UiHandler。
5.责任人（UiHandler）处理最后逻辑。

1.接收异步请求方法：

public void sendBackgroundMessage(int what, Object object) {
    Message message = this.obtainBackgroundMessage();
    message.what = what;
    message.obj = object;
    this.sendBackgroundMessage(message);
}
public Message obtainBackgroundMessage() 
    return this.mBackgroundHandler.obtainMessage();
}

2.发消息给BackGroundHandler：

public void sendBackgroundMessage(Message message) {
    this.mBackgroundHandler.sendMessage(message);
}

3.BackgroudHandler处理异步逻辑：

 private static class BackgroundHandler extends Handler {
    private  WeakReference<HandlerManager> mActivityReference;
    BackgroundHandler(HandlerManager manager, Looper looper) {
        super(looper);
        this.mActivityReference = new WeakReference(manager);
    }
    //发送消息
    public void handleMessage(Message msg) {
        super.handleMessage(msg);
        //如果引用不为空，发送消息
        if(this.mActivityReference.get() != null) {
 ((HandlerManager)this.mActivityReference.get()).handleBackgroundMessage(msg);
        }
    }
}
public abstract void handleBackgroundMessage(Message var1);

4.Manager拿到处理结果发消息给UiHandler:

public void sendUiMessage(int what, Object obj, long delay) {
    Message me = this.obtainUiMessage();
    me.what = what;
    me.obj = obj;
    this.sendUiMessage(me, delay);
}
public void sendUiMessage(Message message, long delay) {
    this.mUiHandler.sendMessageDelayed(message, delay);
}

5.UiHandler处理最后逻辑：

private static class UiHandler extends Handler {
    private  WeakReference<HandlerManager> mActivityReference;
    public UiHandler(HandlerManager manager) {
        this.mActivityReference = new WeakReference(manager);
    }
    public void handleMessage(Message msg) {
        super.handleMessage(msg);
        if(this.mActivityReference.get() != null) {
            ((HandlerManager)this.mActivityReference.get()).handleUiMessage(msg);
        }
    }
}
public abstract void handleUiMessage(Message var1);

最后附带完整代码：

public abstract class HandlerManager {
private HandlerThread mHandlerThread;//含有Looper的Thread
private BackgroundHandler mBackgroundHandler;//后台接收消息的handler载体
private Handler mUiHandler;//主线程接收消息的handler载体

public HandlerManager() {
}
//给主线直接发送message对象
public void sendUiMessage(Message message) {
    this.mUiHandler.sendMessage(message);
}
//给主线程发送what和obj，自动组合成message对象
public void sendUiMessage(int what, Object object) {
    Message message = this.obtainUiMessage();
    message.what = what;
    message.obj = object;
    this.sendUiMessage(message);
}
//给主线程发送空消息
public void sendUiMessage(int what) {
    this.mUiHandler.sendEmptyMessage(what);
}
//给主线程发送延迟消息
public void sendUiMessage(int what, long delay) {
    this.mUiHandler.sendEmptyMessageDelayed(what, delay);
}
//给主线程发送what和obj，自动组合成message对象（带延迟）
public void sendUiMessage(int what, Object obj, long delay) {
    Message me = this.obtainUiMessage();
    me.what = what;
    me.obj = obj;
    this.sendUiMessage(me, delay);
}
//给主线直接发送message对象（带延迟）
public void sendUiMessage(Message message, long delay) {
    this.mUiHandler.sendMessageDelayed(message, delay);
}
//给后台线程发送message对象（带延迟）
public void sendBackgroundMessage(Message message, long delay) {
    this.mBackgroundHandler.sendMessageDelayed(message, delay);
}
//给后台线程发送what和obj，自动组合成message对象（带延迟）
public void sendBackgroundMessage(int what, Object object, long delay) {
    Message me = this.obtainBackgroundMessage();
    me.what = what;
    me.obj = object;
    this.sendBackgroundMessage(me, delay);
}

public Message obtainUiMessage() {
    return this.mUiHandler.obtainMessage();
}
//给后台线程发送message对象
public void sendBackgroundMessage(Message message) {
    this.mBackgroundHandler.sendMessage(message);
}
//给后台线程发送what和obj，自动组合成message对象
public void sendBackgroundMessage(int what, Object object) {
    Message message = this.obtainBackgroundMessage();
    message.what = what;
    message.obj = object;
    this.sendBackgroundMessage(message);
}
//给后台线程发送空消息
public void sendBackgroundMessage(int what) {
    this.mBackgroundHandler.sendEmptyMessage(what);
}
//给主线程发送空消息（带延迟）
public void sendBackgroundMessage(int what, long delay) {
    this.mBackgroundHandler.sendEmptyMessageDelayed(what, delay);
}

public Message obtainBackgroundMessage() {
    return this.mBackgroundHandler.obtainMessage();
}
//初始化handlermanager对象
public void oncreate() {
    this.mHandlerThread 
        = new HandlerThread("activity worker:" 
            + this.getClass().getSimpleName());
    this.mHandlerThread.start();
    this.mBackgroundHandler 
        = new BackgroundHandler(this, this.mHandlerThread.getLooper());
    this.mUiHandler = new UiHandler(this);
}
//清空HandlerManager对象中数据，防止内存泄漏
public void onDestroy() {
    if(this.mBackgroundHandler != null &&
        this.mBackgroundHandler.getLooper() != null) {
        this.mBackgroundHandler.getLooper().quit();
    }

}

public abstract void handleBackgroundMessage(Message var1);

public abstract void handleUiMessage(Message var1);
/**
 * UI线程
 * */
private static class UiHandler extends Handler {
    //HandlerManager 的弱引用，防止内存泄漏
    private  WeakReference<HandlerManager> mActivityReference;

    public UiHandler(HandlerManager manager) {
        this.mActivityReference = new WeakReference(manager);
    }

    public void handleMessage(Message msg) {
        super.handleMessage(msg);
        //如果引用不为空，发送消息
        if(this.mActivityReference.get() != null) {
            ((HandlerManager)this.mActivityReference.get())
                .handleUiMessage(msg);
        }

    }
}
/**
 * 后台线程
 * */
private static class BackgroundHandler extends Handler {
    //HandlerManager 的弱引用，防止内存泄漏
    private  WeakReference<HandlerManager> mActivityReference;

    BackgroundHandler(HandlerManager manager, Looper looper) {
        super(looper);
        this.mActivityReference = new WeakReference(manager);
    }
    //发送消息
    public void handleMessage(Message msg) {
        super.handleMessage(msg);
        //如果引用不为空，发送消息
        if(this.mActivityReference.get() != null) {
            ((HandlerManager)this.mActivityReference.get())
                  .handleBackgroundMessage(msg);
        }

    }
}

下面是调用代码（建议写在BaseActivity中）：

private HandlerManager handlerManager;//线程管理器
private void initHandle() {
    this.handlerManager = new HandlerManager() {
        public void handleBackgroundMessage(Message message) {
            BaseActivity.this.handleBackgroundMessage(message);
        }

        public void handleUiMessage(Message message) {
            BaseActivity.this.handleUiMessage(message);
        }
    };
    this.handlerManager.oncreate();
}

 public void onDestroy() {
    super.onDestroy();
    this.handlerManager.onDestroy();
}

 @Override
public void sendUiMessage(Message var1) {
    handlerManager.sendUiMessage(var1);
}

@Override
public void sendUiMessage(int var1, Object var2) {
    handlerManager.sendUiMessage(var1, var2);
}

@Override
public void sendUiMessage(int var1) {
    handlerManager.sendUiMessage(var1);
}

@Override
public void sendUiMessage(int var1, long var2) {
    handlerManager.sendUiMessage(var1, var2);
}

@Override
public void sendUiMessage(int var1, Object var2, long var3) {
    handlerManager.sendUiMessage(var1, var2, var3);
}

@Override
public void sendUiMessage(Message var1, long var2) {
    handlerManager.sendUiMessage(var1, var2);
}

 @Override
public void sendBackgroundMessage(Message var1) {
    handlerManager.sendBackgroundMessage(var1);
}

@Override
public void sendBackgroundMessage(int var1, Object var2) {
    handlerManager.sendBackgroundMessage(var1,var2);
}

@Override
public void sendBackgroundMessage(int var1) {
    handlerManager.sendBackgroundMessage(var1);
}

@Override
public void sendBackgroundMessage(int var1, long var2) {
    handlerManager.sendBackgroundMessage(var1,var2);
}

@Override
public void sendBackgroundMessage(int var1, Object var2, long var3) {
    handlerManager.sendBackgroundMessage(var1,var2,var3);
}

@Override
public void sendBackgroundMessage(Message var1, long var2) {
    handlerManager.sendBackgroundMessage(var1,var2);
}

@Override
public void handleBackgroundMessage(Message var1) {
}

@Override
public void handleUiMessage(Message var1) {
}

二维码.jpg

推荐下本人的微信公众号，本博客及其他方面的消息会定期同步到公众号上面！

最后编辑于：2018.05.31 15:21:37

人面猴
序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
沈念sama阅读 214,717评论 6赞 496
死咒
序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
沈念sama阅读 91,501评论 3赞 389
救了他两次的神仙让他今天三更去死
文/潘晓璐我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
开封第一讲书人阅读 160,311评论 0赞 350
道士缉凶录：失踪的卖姜人
文/不坏的土叔我叫张陵，是天一观的道长。经常有香客问我，道长，这世上最难降的妖魔是什么？我笑而不...
开封第一讲书人阅读 57,417评论 1赞 288
港岛之恋（遗憾婚礼）
正文为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
茶点故事阅读 66,500评论 6赞 386
恶毒庶女顶嫁案：这布局不是一般人想出来的
文/花漫我一把揭开白布。她就那样静静地躺着，像睡着了一般。火红的嫁衣衬着肌肤如雪。梳的纹丝不乱的头发上，一...
开封第一讲书人阅读 50,538评论 1赞 293
城市分裂传说
那天，我揣着相机与录音，去河边找鬼。笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。我是一名探鬼主播，决...
沈念sama阅读 39,557评论 3赞 414
双鸳鸯连环套：你想象不到人心有多黑
文/苍兰香墨我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
开封第一讲书人阅读 38,310评论 0赞 270
万荣杀人案实录
序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
沈念sama阅读 44,759评论 1赞 307
护林员之死
正文独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋以下内容为张勋视角年9月15日...
茶点故事阅读 37,065评论 2赞 330
白月光启示录
正文我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
茶点故事阅读 39,233评论 1赞 343
活死人
序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
沈念sama阅读 34,909评论 5赞 338
日本核电站爆炸内幕
正文年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
茶点故事阅读 40,548评论 3赞 322
男人毒药：我在死后第九天来索命
文/蒙蒙一、第九天我趴在偏房一处隐蔽的房顶上张望。院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
开封第一讲书人阅读 31,172评论 0赞 21
一桩弑父案，背后竟有这般阴谋
文/苍兰香墨我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。一阵脚步声响...
开封第一讲书人阅读 32,420评论 1赞 268
情欲美人皮
我被黑心中介骗来泰国打工，没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。一个月前我还...
沈念sama阅读 47,103评论 2赞 365
代替公主和亲
正文我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
茶点故事阅读 44,098评论 2赞 352

Android 自定义线程管理器（串行）

首先我们需要创建一个线程：

第二我们线程管理器只是管理线程，不进行具体的逻辑操作，那么就用到了Handler机制：

第三我们就要发送消息了，先理清逻辑：

最后附带完整代码：

推荐阅读更多精彩内容