文档章节

android封装工作线程跟Handler工具类

WalkingMo
 WalkingMo
发布于 2017/05/05 11:00
字数 433
阅读 155
收藏 0
点赞 0
评论 0

直接上代码,不解说 - -

基于MVP封装P的基类

AbsHandlerThreadHelper.java

import java.lang.ref.WeakReference;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

import android.content.Context;
import android.os.Handler;
import android.os.Message;

public abstract class AbsHandlerThreadHelper<T extends Context> {

	protected ExecutorService mExecutorService;

	private WeakReference<T> mContextWeakReference;

	protected HandlerInner<T> mHandler;

	protected static class HandlerInner<T  extends Context> extends Handler {

		private WeakReference<AbsHandlerThreadHelper<T>> mWeakReference;

		public HandlerInner(AbsHandlerThreadHelper<T> handlerThreadHelper) {
			super();
			this.mWeakReference = new WeakReference<AbsHandlerThreadHelper<T>>(handlerThreadHelper);
		}

		@Override
		public void dispatchMessage(Message msg) {
			super.dispatchMessage(msg);
			AbsHandlerThreadHelper<T> handlerThreadHelper = mWeakReference.get();
			if (handlerThreadHelper != null) {
				handlerThreadHelper.dispatchMessage(msg);
			}
		}
	}

	public AbsHandlerThreadHelper(T t) {
		super();
		this.mContextWeakReference = new WeakReference<T>(t);
		init();
	}

	private void init() {
		mExecutorService = Executors.newCachedThreadPool();
		mHandler = new HandlerInner<T>(this);
	}

	public T getContext() {
		return mContextWeakReference.get();
	}

	public abstract void dispatchMessage(Message msg);

	public void onPreDestroy() {
		onDestroy();
		if (mExecutorService != null) {
			mExecutorService.shutdown();
		}
		mExecutorService = null;
		if (mHandler != null) {
			mHandler.removeCallbacksAndMessages(null);
		}
		mHandler = null;
		if (mContextWeakReference != null) {
			mContextWeakReference.clear();
		}
		mContextWeakReference = null;
	}

	public abstract void onDestroy();
}

线程的基类

AbsThread.java

import java.lang.ref.WeakReference;

import android.content.Context;

public abstract class AbsThread<T extends Context> implements Runnable {

	protected WeakReference<AbsHandlerThreadHelper<T>> mReference;

	public AbsThread(AbsHandlerThreadHelper<T> handlerThreadHelper) {
		super();
		this.mReference = new WeakReference<AbsHandlerThreadHelper<T>>(handlerThreadHelper);
	}

	@Override
	public void run() {
		synchronized (this) {
			AbsHandlerThreadHelper<T> handlerThreadHelper = mReference.get();
			if (handlerThreadHelper != null) {
				runPro();
			}
		}
	}

	public  abstract  void runPro();
}

我用的是okhttp3的,所以封装多一个AbsOkHttpThread.java

import java.io.IOException;

import android.content.Context;
import android.os.Message;
import okhttp3.Call;
import okhttp3.Callback;
import okhttp3.Response;

public abstract class AbsOkHttpThread<T extends Context> extends AbsThread<T> implements Callback {

	private int success = 0;

	private int fail = -1;

	public AbsOkHttpThread(AbsHandlerThreadHelper<T> handlerThreadHelper) {
		super(handlerThreadHelper);
	}

	public AbsOkHttpThread(AbsHandlerThreadHelper<T> handlerThreadHelper, int success, int fail) {
		super(handlerThreadHelper);
		this.success = success;
		this.fail = fail;
	}

	@Override
	public void onFailure(Call call, IOException exception) {
		AbsHandlerThreadHelper<T> handlerThreadHelper = mReference.get();
		if (handlerThreadHelper != null) {
			handlerThreadHelper.mHandler.sendEmptyMessage(fail);
		}
	}

	@Override
	public void onResponse(Call call, Response response) throws IOException {
		try {
			AbsHandlerThreadHelper<T> handlerThreadHelper = mReference.get();
			if (handlerThreadHelper != null) {
				Message msg  = new Message();
				//TODO call
				final String result = response.body().string();
				msg.obj = result;
				msg.what = success;
				handlerThreadHelper.mHandler.sendMessage(msg);
			}
		} catch (Exception e) {
			onFailure(call, null);
		}
	}
}

例子DemoPresenter.java

import android.app.Service;
import android.os.Message;

public class DemoPresenter extends AbsHandlerThreadHelper<Service> {

	private TestRun testRun;

	public DemoPresenter(Service t) {
		super(t);
		testRun = new TestRun(this, 3, 2);
	}

	@Override
	public void dispatchMessage(Message msg) {
		LogDebug.e(getContext(), "DemoPresenter.dispatchMessage:" + msg.what);
	}

	@Override
	public void onDestroy() {

	}

	public void register() {
		mExecutorService.execute(testRun);
	}

	private static class TestRun extends AbsOkHttpThread<Service> {

		public TestRun(AbsHandlerThreadHelper<Service> handlerThreadHelper, int success, int fail) {
			super(handlerThreadHelper, success, fail);
		}

		@Override
		public void runPro() {
			AbsHandlerThreadHelper<Service> absHandlerThreadHelper = mReference.get();
			Service context = absHandlerThreadHelper.getContext();
			if (context != null) {
				OkHttp3Utils.getInstance(context).doPostPro("http://www.google.com", null, "{}", this);
			}
		}
	}
}

 

© 著作权归作者所有

共有 人打赏支持
WalkingMo
粉丝 52
博文 336
码字总数 116759
作品 0
东莞
程序员
音视频直播技术--Android视频采集(Camera2)

介绍 今天为大家介绍一下如何在 Android 上进行视频采集。在 Android 系统下有两套 API 可以进行视频采集,它们是 Camera 和 Camera2 。Camera是以前老的 API ,从 Android 5.0(21)之后就已经...

音视频直播技术专家 ⋅ 2017/07/24 ⋅ 0

Android Handler异步通信:深入详解Handler机制源码

前言 在开发的多线程应用场景中,机制十分常用 今天,我将手把手带你深入分析 机制的源码,希望你们会喜欢 目录 1. Handler 机制简介 在多线程的应用场景中,将工作线程中需更新的操作信息 ...

carson_ho ⋅ 05/21 ⋅ 0

说说在 Android 中如何实现多线程编程

当我们执行一些耗时操作,比如发起一条网络请求时,考虑到网速等其他因素,服务器未必会立刻响应我们的请求,那么就必须将这类操作放在子线程中运行,这就需要实现多线程编程。 1 启动线程 ...

deniro ⋅ 06/18 ⋅ 0

Android性能优化:关于 内存泄露 的知识都在这里了!

前言 在中,内存泄露的现象十分常见;而内存泄露导致的后果会使得应用 本文 全面介绍了内存泄露的本质、原因 & 解决方案,最终提供一些常见的内存泄露分析工具,希望你们会喜欢。 目录 } Li...

Carson_Ho ⋅ 04/19 ⋅ 0

Handler消息处理机制分析

Handler经常用,然后自己总结一下下 一. What、Handler 是什么 Handler 与 Message、MessageQueue、Looper 一起构成了 Android 的消息机制,Android 系统通过大量的消息来与用户进行交互,V...

大二架构师 ⋅ 05/07 ⋅ 0

对Android Handler Message Looper常见用法,知识点的一些总结

Android 非UI线程中是不能更新UI的,Handler是Android 提供的一套更新UI的机制,也是用来发送消息和处理消息的一套机制。 以前刚接触的Handler的时候,感觉总是很困惑,对Handler原理也是一知...

猴亮屏 ⋅ 06/11 ⋅ 0

Handler和AsyncTask

在Android中实现异步任务机制有两种方式,Handler和AsyncTask。 Handler模式需要为每一个任务创建一个新的线程,任务完成后通过Handler实例向UI线程发送消息,完成界面的更新,这种方式对于整...

hisense20112784 ⋅ 2017/06/03 ⋅ 0

android消息机制,异步和多线程

android消息机制,异步和多线程 前言 在xxxx1.92正式版的时候付费购买曾单独封装了一个流程PaymentFlow并继承于Handler,调用方只要依据这个流程创建流程实例并触发开始,实例即可依据设定的支付...

ZHL ⋅ 2012/09/03 ⋅ 0

Android 内存泄露的几中场景

title: Android 内存泄露的几中场景 date: 2016-11-22 13:57 tags: Android Android 内存泄漏 java 存在一个垃圾回收机制,发生泄漏的原因就是应该被回收的垃圾没有被回收,这种情况就叫做内...

WooiiiWooiii ⋅ 2016/12/21 ⋅ 0

关于Activity销毁,而绘制UI的子线程未销毁出现的问题

项目总结 --------------------------------------------------------------------------------------------------------- 有一个功能模块,需要播放音频,画一个简单的界面 一个例子: 我们...

听着music睡 ⋅ 2015/11/12 ⋅ 0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

知乎Java数据结构

作者:匿名用户 链接:https://www.zhihu.com/question/35947829/answer/66113038 来源:知乎 著作权归作者所有。商业转载请联系作者获得授权,非商业转载请注明出处。 感觉知乎上嘲讽题主简...

颖伙虫 ⋅ 今天 ⋅ 0

Confluence 6 恢复一个站点有关使用站点导出为备份的说明

推荐使用生产备份策略。我们推荐你针对你的生产环境中使用的 Confluence 参考 Production Backup Strategy 页面中的内容进行备份和恢复(这个需要你备份你的数据库和 home 目录)。XML 导出备...

honeymose ⋅ 今天 ⋅ 0

JavaScript零基础入门——(九)JavaScript的函数

JavaScript零基础入门——(九)JavaScript的函数 欢迎回到我们的JavaScript零基础入门,上一节课我们了解了有关JS中数组的相关知识点,不知道大家有没有自己去敲一敲,消化一下?这一节课,...

JandenMa ⋅ 今天 ⋅ 0

火狐浏览器各版本下载及插件httprequest

各版本下载地址:http://ftp.mozilla.org/pub/mozilla.org//firefox/releases/ httprequest插件截至57版本可用

xiaoge2016 ⋅ 今天 ⋅ 0

Docker系列教程28-实战:使用Docker Compose运行ELK

原文:http://www.itmuch.com/docker/28-docker-compose-in-action-elk/,转载请说明出处。 ElasticSearch【存储】 Logtash【日志聚合器】 Kibana【界面】 答案: version: '2'services: ...

周立_ITMuch ⋅ 今天 ⋅ 0

使用快嘉sdkg极速搭建接口模拟系统

在具体项目研发过程中,一旦前后端双方约定好接口,前端和app同事就会希望后台同事可以尽快提供可供对接的接口方便调试,而对后台同事来说定好接口还仅是个开始、设计流程,实现业务逻辑,编...

fastjrun ⋅ 今天 ⋅ 0

PXE/KickStart 无人值守安装

导言 作为中小公司的运维,经常会遇到一些机械式的重复工作,例如:有时公司同时上线几十甚至上百台服务器,而且需要我们在短时间内完成系统安装。 常规的办法有什么? 光盘安装系统 ===> 一...

kangvcar ⋅ 昨天 ⋅ 0

使用Puppeteer撸一个爬虫

Puppeteer是什么 puppeteer是谷歌chrome团队官方开发的一个无界面(Headless)chrome工具。Chrome Headless将成为web应用自动化测试的行业标杆。所以我们很有必要来了解一下它。所谓的无头浏...

小草先森 ⋅ 昨天 ⋅ 0

Java Done Right

* 表示难度较大或理论性较强。 ** 表示难度更大或理论性更强。 【Java语言本身】 基础语法,面向对象,顺序编程,并发编程,网络编程,泛型,注解,lambda(Java8),module(Java9),var(...

风华神使 ⋅ 昨天 ⋅ 0

Linux系统日志

linux 系统日志 /var/log/messages /etc/logrotate.conf 日志切割配置文件 https://my.oschina.net/u/2000675/blog/908189 logrotate 使用详解 dmesg 命令 /var/log/dmesg 日志 last命令,调......

Linux学习笔记 ⋅ 昨天 ⋅ 0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

返回顶部
顶部