fix bug https://github.com/AriaLyy/Aria/issues/105

Aria/src/main/java/com/arialyy/aria/core/command/normal/ResumeAllCmd.java

@@ -39,19 +39,23 @@ final class ResumeAllCmd<T extends AbsTaskEntity> extends AbsNormalCmd<T> {
   private void resumeDownload() {
     List<DownloadTaskEntity> dTaskEntity =
         DbEntity.findDatas(DownloadTaskEntity.class, "isGroupTask=?", "false");
+    if (dTaskEntity != null && !dTaskEntity.isEmpty()) {
       for (DownloadTaskEntity te : dTaskEntity) {
         int state = te.getState();
         if (state == IEntity.STATE_COMPLETE || state == IEntity.STATE_FAIL) continue;
         resumeEntity(te);
       }
+    }
 
     List<DownloadGroupTaskEntity> groupTask = DbEntity.findAllData(DownloadGroupTaskEntity.class);
+    if (groupTask != null && !groupTask.isEmpty()) {
       for (DownloadGroupTaskEntity te : groupTask) {
         int state = te.getState();
         if (state == IEntity.STATE_COMPLETE || state == IEntity.STATE_FAIL) continue;
         resumeEntity(te);
       }
     }
+  }
 
   /**
    * 恢复上传，包括普通任务和任务组
@@ -59,12 +63,14 @@ final class ResumeAllCmd<T extends AbsTaskEntity> extends AbsNormalCmd<T> {
   private void resumeUpload() {
     List<UploadTaskEntity> dTaskEntity =
         DbEntity.findDatas(UploadTaskEntity.class, "isGroupTask=?", "false");
+    if (dTaskEntity != null && !dTaskEntity.isEmpty()) {
       for (UploadTaskEntity te : dTaskEntity) {
         int state = te.getState();
         if (state == IEntity.STATE_COMPLETE || state == IEntity.STATE_FAIL) continue;
         resumeEntity(te);
       }
     }
+  }
 
   /**
    * 恢复实体任务

Aria/src/main/java/com/arialyy/aria/core/queue/AbsTaskQueue.java

@@ -26,7 +26,9 @@ import com.arialyy.aria.core.inf.AbsTaskEntity;
 import com.arialyy.aria.core.inf.IEntity;
 import com.arialyy.aria.core.queue.pool.BaseCachePool;
 import com.arialyy.aria.core.queue.pool.BaseExecutePool;
+import java.security.Key;
 import java.util.Iterator;
+import java.util.Map;
 import java.util.Set;
 
 /**
@@ -66,13 +68,11 @@ abstract class AbsTaskQueue<TASK extends AbsTask, TASK_ENTITY extends AbsTaskEnt
    * 停止所有任务
    */
   @Override public void stopAllTask() {
+    mCachePool.clear();
     for (String key : mExecutePool.getAllTask().keySet()) {
       TASK task = mExecutePool.getAllTask().get(key);
       if (task != null && task.isRunning()) task.stop();
     }
-    for (String key : mCachePool.getAllTask().keySet()) {
-      mCachePool.removeTask(key);
-    }
   }
 
   @Override public int getMaxTaskNum() {

Aria/src/main/java/com/arialyy/aria/core/queue/pool/BaseCachePool.java

@@ -53,6 +53,17 @@ public class BaseCachePool<TASK extends AbsTask> implements IPool<TASK> {
     return mCacheMap;
   }
 
+  /**
+   * 清除所有缓存的任务
+   */
+  public void clear(){
+    for (String key : mCacheMap.keySet()){
+      TASK task = mCacheMap.get(key);
+      mCacheQueue.remove(task);
+      mCacheMap.remove(key);
+    }
+  }
+
   /**
    * 将任务放在队首
    */