文档章节

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

moz1q1
 moz1q1
发布于 2017/05/05 11:00
字数 433
阅读 172
收藏 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);
			}
		}
	}
}

 

© 著作权归作者所有

共有 人打赏支持
moz1q1
粉丝 55
博文 351
码字总数 117569
作品 0
东莞
程序员
私信 提问
android的消息处理机制(图+源码分析)——Looper,Handler,Message

作为一个大三的预备程序员,我学习android的一大乐趣是可以通过源码学习google大牛们的设计思想。android源码中包含了大量的设计模式,除此以外,android sdk还精心为我们设计了各种helper类...

火蚁
2014/05/14
0
0
Android的消息处理机制(图+源码分析)——Looper,Handler,Message

作为一个大三的预备程序员,我学习android的一大乐趣是可以通过源码学习google大牛们的设计思想。android源码中包含了大量的设 计模式,除此以外,android sdk还精心为我们设计了各种helper类...

Jerikc
2013/12/28
0
0
android消息机制,异步和多线程

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

ZHL
2012/09/03
0
0
android的消息处理机制——Looper,Handler,Message

这篇文章有一半是copy别人的,站在巨人的肩膀上,我们才能看得更高更远...... 在开始讨论android的消息处理机制前,先来谈谈一些基本相关的术语。 通信的同步(Synchronous):指向客户端发送...

LionSword
2014/06/22
0
0
Android 中Message,MessageQueue,Looper,Handle

一、几个关键概念 1、MessageQueue:是一种数据结构,见名知义,就是一个消息队列,存放消息的地方。每一个线程最多只可以拥有一个MessageQueue数据结构。 创建一个线程的时候,并不会自动创...

geek_loser
2015/10/30
0
0

没有更多内容

加载失败,请刷新页面

加载更多

Spak—— sparkCore源码解析之RangePartitioner源码

   分区过程概览 RangePartitioner分区执行原理: 计算总体的数据抽样大小sampleSize,计算规则是:至少每个分区抽取20个数据或者最多1M的数据量。 根据sampleSize和分区数量计算每个分区的...

freeli
13分钟前
1
0
从内部自用到对外服务,配置管理的演进和设计优化实践

本文整理自阿里巴巴中间件技术专家彦林在中国开源年会上的分享,通过此文,您将了解到: 微服务给配置管理所带来的变化 配置管理演进过程中的设计思考 配置管理开源后的新探索 配置中心控制台...

阿里云官方博客
14分钟前
0
0
MySQL用户管理,常用MySQL语句、MySQL数据库备份恢复

12月6日任务 13.4 mysql用户管理 13.5 常用sql语句 13.6 mysql数据库备份恢复 13.4 mysql用户管理 grant all on *.* to 'user1' identified by 'passwd'; grant SELECT,UPDATE,INSERT on db......

zgxlinux
15分钟前
1
0
Spring异常之Druid – unregister mbean error

Spring异常之Druid – unregister mbean error 2017年04月19日 12:13:42 Dr.Zhu 阅读数:6688 版权声明:本文为博主原创文章,未经博主允许不得转载。 https://blog.csdn.net/zt_fucker/arti...

linjin200
20分钟前
1
0
微信小程序webview问题

今天在改小程序的时候在使用webview的时候切换webview的地址行为,出现了诡异的情况。 默认querystring里会有多个?符号,使用的时候被微信给截取了,导致程序找不到改页面。 而且querystri...

钟元OSS
23分钟前
1
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部