diff --git a/PublicComponent/src/main/java/com/arialyy/aria/core/group/AbsSubDLoadUtil.java b/PublicComponent/src/main/java/com/arialyy/aria/core/group/AbsSubDLoadUtil.java index 1af9c2fa..3ddcc0ad 100644 --- a/PublicComponent/src/main/java/com/arialyy/aria/core/group/AbsSubDLoadUtil.java +++ b/PublicComponent/src/main/java/com/arialyy/aria/core/group/AbsSubDLoadUtil.java @@ -44,7 +44,6 @@ public abstract class AbsSubDLoadUtil implements IUtil, Runnable { private boolean needGetInfo; private boolean isStop = false, isCancel = false; private String parentKey; - private IDLoadListener mListener; /** * @param schedulers 调度器 @@ -53,62 +52,10 @@ public abstract class AbsSubDLoadUtil implements IUtil, Runnable { protected AbsSubDLoadUtil(DTaskWrapper taskWrapper, Handler schedulers, boolean needGetInfo, String parentKey) { mWrapper = taskWrapper; mSchedulers = schedulers; - mListener=createListener(); this.parentKey = parentKey; this.needGetInfo = needGetInfo; mDLoader = getLoader(); } - private IDLoadListener createListener() { - return new IDLoadListener() { - @Override - public void onPostPre(long fileSize) { - } - - @Override - public void supportBreakpoint(boolean support) { - } - - @Override - public void onPre() { - } - - @Override - public void onStart(long startLocation) { - } - - @Override - public void onResume(long resumeLocation) { - } - - @Override - public void onProgress(long currentLocation) { - Message msg =getSchedulers().obtainMessage(IThreadStateManager.STATE_RUNNING, currentLocation); - Bundle b = new Bundle(); - msg.setData(b); - b.putString(IThreadStateManager.DATA_THREAD_NAME, getKey()); - msg.sendToTarget(); - } - - @Override - public void onStop(long stopLocation) { - } - - @Override - public void onComplete() { - } - - @Override - public void onCancel() { - } - - @Override - public void onFail(boolean needRetry, AriaException e) { - } - - - }; - - } /** * 创建加载器 @@ -150,7 +97,7 @@ public abstract class AbsSubDLoadUtil implements IUtil, Runnable { return; } buildLoaderStructure(); - mDLoader.run(); + new Thread(mDLoader).start(); } /**