NoHttp封装--07 自定义异步任务框架
2024-03-26 17:37:18
MainActivity：
public class MainActivity extends Activity implements View.OnClickListener {
....
@Override
public void onClick(View v) {
MultiAsynctaskNetwork network = new MultiAsynctaskNetwork(networkInterface);
network.execute();
}
private NetworkInterface networkInterface = new NetworkInterface() {
@Override
public void onResult(String result) {
mTvResult.setText(result);
}
};
}
NetworkInterface：
public interface NetworkInterface {
void onResult(String result);
}
MultiAsynctaskNetwork：
public class MultiAsynctaskNetwork extends MultiAsynctask<Void, Integer, String> {
private NetworkInterface mInterface;
public MultiAsynctaskNetwork(NetworkInterface networkInterface) {
this.mInterface = networkInterface;
}
@Override
protected String onExecuteTask(Void... params) {
HttpURLConnection connection = null;
try {
URL url = new URL("http://blog.csdn.net/yanzhenjie1003");
connection = (HttpURLConnection) url.openConnection();
int responseCode = connection.getResponseCode();
if (responseCode == ) {
int len = ;
byte[] buffer = new byte[];
ByteArrayOutputStream arrayOutputStream = new ByteArrayOutputStream();
InputStream inputStream = new BufferedInputStream(connection.getInputStream());
while ((len = inputStream.read(buffer)) != -) {
arrayOutputStream.write(buffer, , len);
}
inputStream.close();
arrayOutputStream.flush();
inputStream.close();
return new String(arrayOutputStream.toByteArray());
}
} catch (Exception e) {
e.printStackTrace();
} finally {
if (connection != null)
connection.disconnect();
}
return "请求网络失败";
}
@Override
public void onResult(String result) {// 拿到执行结果，直接更新UI
mInterface.onResult(result);
}
}
核心类MultiAsynctask：
public abstract class MultiAsynctask<Param, Update, Result> {
/**
* 更新的what
*/
private static final int WHAT_UPDATE = 0x01;
/**
* 发送结果的what
*/
private static final int WHAT_RESULT = 0x02;
/**
* 默认的线程池
*/
private static ExecutorService sExecutorService;
/**
* 默认并发大小
*/
private static final int DEFAULT_POOL_SIZE = ;
/**
* 发送结果的Handler
*/
private static Handler sHandler;
/**
* Handler的锁
*/
private static Object HANDLER_LOCK = new Object();
/**
* 本地异步任务的执行器
*/
private ExecutorService mExecutorService = null;
public MultiAsynctask() {
this(getDufaultExecutor());
}
public MultiAsynctask(ExecutorService executorService) {
mExecutorService = executorService;
}
/**
* 拿到默认的线程池
*
* @return
*/
private static ExecutorService getDufaultExecutor() {
synchronized (MultiAsynctask.class) {
if (sExecutorService == null)
sExecutorService = Executors.newFixedThreadPool(DEFAULT_POOL_SIZE);
return sExecutorService;
}
}
/**
* 设置默认的线程池
*
* @param executorService
*/
public static void setDefaultExecutor(ExecutorService executorService) {
synchronized (MultiAsynctask.class) {
sExecutorService = executorService;
}
}
public static Handler getDefaultPoster() {
synchronized (HANDLER_LOCK) {
if (sHandler == null)
sHandler = new Poster();
return sHandler;
}
}
/**
* 开始执行任务
*
* @param params
*/
public final void execute(Param... params) {
mExecutorService.execute(new Tasker(params));
}
protected abstract Result onExecuteTask(Param... params);
/**
* 发送进度更新到主线程
*
* @param update
*/
public final void onPostUpdate(Update update) {
Message.obtain();
Message message = getDefaultPoster().obtainMessage();
message.what = WHAT_UPDATE;
message.obj = new Messager<Param, Update, Result>(this, update, null);
message.sendToTarget();
}
/**
* 当返回进度更新的时候
*
* @param update
*/
protected void onUpdate(Update update) {
}
/**
* 发送进度执行结果到主线程
*
* @param result
*/
public final void onPostResult(Result result) {
Message.obtain();
Message message = getDefaultPoster().obtainMessage();
message.what = WHAT_RESULT;
message.obj = new Messager<Param, Update, Result>(this, null, result);
message.sendToTarget();
}
/**
* 当返回执行结果的时候
*
* @param result
*/
protected void onResult(Result result) {
}
private static class Messager<Param, Update, Result> {
private final MultiAsynctask<Param, Update, Result> asynctask;
private final Update update;
private final Result result;
public Messager(MultiAsynctask<Param, Update, Result> asynctask, Update update, Result result) {
this.asynctask = asynctask;
this.update = update;
this.result = result;
}
/**
* 调用当前MultiAsynctask的主线程更新方法
*/
public void onUpdate() {
asynctask.onUpdate(update);
}
/**
* 调用当前MultiAsynctask的主线程结果方法
*/
public void onResult() {
asynctask.onResult(result);
}
}
/**
* <p>
* 线程间通信使者
* </p>
* Created in Mar 27, 2016 10:00:03 PM.
*
* @author Yolanda;
*/
private static class Poster extends Handler {
public Poster() {
super(Looper.getMainLooper());
}
@Override
public void handleMessage(Message msg) {
Messager<?, ?, ?> messageer = (Messager<?, ?, ?>) msg.obj;
if (msg.what == WHAT_RESULT) {
messageer.onResult();
} else if (msg.what == WHAT_UPDATE) {
messageer.onUpdate();
}
}
}
/**
* <p>
* 任务执行器
* </p>
* Created in Mar 27, 2016 10:03:44 PM.
*
* @author Yolanda;
*/
private class Tasker implements Runnable {
private Param[] params;
public Tasker(Param... params) {
this.params = params;
}
@Override
public void run() {
Result result = onExecuteTask(params);
onPostResult(result);
}
}
}
最新文章
- TDR分辨率
- Linux -- CentOS7修改防护墙端口
- tab切换-淘宝案例
- CLR via C#（02）-基元类型、引用类型、值类型
- 洛谷 P1019 单词接龙 Label:dfs
- Mifare Classic Tool(MCT)汉化版
- thymeleaf中的模板布局
- 防止非授权用户调用DLL
- Python 对新浪微博的博文元素 (Word, Screen Name)的频率分析
- [BZOJ 1257] [CQOI2007] 余数之和sum 【数学】
- Android（java）学习笔记227：服务（service）之服务的生命周期 与 两种启动服务的区别
- 类库dll引用不成功问题
- 一起talk C栗子吧（第二十回：C语言实例--括号匹配）
- Oracle "Job定时"
- 老李推荐： 第8章4节《MonkeyRunner源码剖析》MonkeyRunner启动运行过程-启动AndroidDebugBridge 4
- 如何直接在github上预览html网页效果
- Mac 下编译安装 php-5.6
- [Day14]Eclipse高级、类与接口作为参数返回值
- TCP、UDP之三次握手四次挥手
- 微软BI 之SSRS 系列 - 在 Cube 中通过 MDX 查询实现基于父子递归关系的汇总报表
热门文章
- 多线程 Thread.yield 方法到底有什么用？
- js中select标签中的option选择
- win10安装MySQL5.7.21
- 课程五(Sequence Models)，第三周（Sequence models & Attention mechanism） —— 0.Practice questions：Sequence models & Attention mechanism
- MapReduce实现ReduceSideJoin操作
- Js中处理日期加减天数
- Core2.0知识整理
- SQL Server 2008 R2 下如何清理数据库日志文件
- ZOOKEEPER典型应用场景解析
- golang使用chrome headless获取网页内容