diff --git a/Aria/src/main/java/com/arialyy/aria/core/common/AbsFileer.java b/Aria/src/main/java/com/arialyy/aria/core/common/AbsFileer.java
index aa8dc8cd..8308f6b4 100644
--- a/Aria/src/main/java/com/arialyy/aria/core/common/AbsFileer.java
+++ b/Aria/src/main/java/com/arialyy/aria/core/common/AbsFileer.java
@@ -16,6 +16,7 @@
 package com.arialyy.aria.core.common;
 
 import android.content.Context;
+import android.util.SparseArray;
 import com.arialyy.aria.core.AriaManager;
 import com.arialyy.aria.core.download.DownloadEntity;
 import com.arialyy.aria.core.download.DownloadTaskEntity;
@@ -64,11 +65,9 @@ public abstract class AbsFileer<ENTITY extends AbsNormalEntity, TASK_ENTITY exte
   protected StateConstance mConstance;
   //总线程数
   protected int mTotalThreadNum;
-  //启动线程数
-  private int mStartThreadNum;
   //已完成的线程数
   private int mCompleteThreadNum;
-  private Map<Integer, AbsThreadTask> mTask = new HashMap<>();
+  private SparseArray<AbsThreadTask> mTask = new SparseArray<>();
 
   private Timer mTimer;
   @Deprecated private File mConfigFile;
@@ -111,8 +110,7 @@ public abstract class AbsFileer<ENTITY extends AbsNormalEntity, TASK_ENTITY exte
     closeTimer();
     mCompleteThreadNum = 0;
     mTotalThreadNum = 0;
-    mStartThreadNum = 0;
-    if (mTask != null && !mTask.isEmpty()) {
+    if (mTask != null && mTask.size() != 0) {
       for (int i = 0; i < mTask.size(); i++) {
         AbsThreadTask task = mTask.get(i);
         if (task != null && !task.isRunning()) {
@@ -137,7 +135,6 @@ public abstract class AbsFileer<ENTITY extends AbsNormalEntity, TASK_ENTITY exte
     mConstance.TASK_RECORD = mRecord;
     if (!mTaskEntity.isSupportBP()) {
       mTotalThreadNum = 1;
-      mStartThreadNum = 1;
     } else {
       mTotalThreadNum =
           mTaskEntity.isNewTask() ? setNewTaskThreadNum() : mTotalThreadNum;
@@ -252,7 +249,7 @@ public abstract class AbsFileer<ENTITY extends AbsNormalEntity, TASK_ENTITY exte
     closeTimer();
     mConstance.isRunning = false;
     mConstance.isCancel = true;
-    for (int i = 0; i < mStartThreadNum; i++) {
+    for (int i = 0; i < mTask.size(); i++) {
       AbsThreadTask task = mTask.get(i);
       if (task != null) {
         task.cancel();
@@ -266,7 +263,7 @@ public abstract class AbsFileer<ENTITY extends AbsNormalEntity, TASK_ENTITY exte
     mConstance.isRunning = false;
     mConstance.isStop = true;
     if (mConstance.isComplete()) return;
-    for (int i = 0; i < mStartThreadNum; i++) {
+    for (int i = 0; i < mTask.size(); i++) {
       AbsThreadTask task = mTask.get(i);
       if (task != null && !task.isThreadComplete()) {
         task.stop();
@@ -338,7 +335,6 @@ public abstract class AbsFileer<ENTITY extends AbsNormalEntity, TASK_ENTITY exte
         tr.startLocation = 0;
         tr.isComplete = false;
         tr.endLocation = mEntity.getFileSize();
-        mStartThreadNum++;
       } else if (file.length() == mEntity.getFileSize()) {
         tr.isComplete = true;
         mCompleteThreadNum++;
@@ -348,14 +344,11 @@ public abstract class AbsFileer<ENTITY extends AbsNormalEntity, TASK_ENTITY exte
           tr.startLocation = file.length();
           tr.isComplete = false;
         }
-        mStartThreadNum++;
       }
     } else {
       for (ThreadRecord tr : mRecord.threadRecords) {
         if (tr.isComplete) {
           mCompleteThreadNum++;
-        } else {
-          mStartThreadNum++;
         }
       }
     }
@@ -376,7 +369,6 @@ public abstract class AbsFileer<ENTITY extends AbsNormalEntity, TASK_ENTITY exte
         ALog.i(TAG, String.format("分块文件【%s】不存在，该分块将重新开始", temp.getPath()));
         tr.isComplete = false;
         tr.startLocation = -1;
-        mStartThreadNum++;
       } else {
         if (tr.isComplete) {
           mCompleteThreadNum++;
@@ -400,7 +392,6 @@ public abstract class AbsFileer<ENTITY extends AbsNormalEntity, TASK_ENTITY exte
               temp.delete();
               tr.startLocation = i * blockLen;
             }
-            mStartThreadNum++;
           }
         }
       }
@@ -453,7 +444,6 @@ public abstract class AbsFileer<ENTITY extends AbsNormalEntity, TASK_ENTITY exte
           tRecord.isComplete = true;
           continue;
         }
-        mStartThreadNum++;
         if (record != null) {
           Long temp = Long.parseLong(String.valueOf(record));
           tRecord.startLocation = temp > 0 ? temp : 0;
diff --git a/Aria/src/main/java/com/arialyy/aria/core/common/AbsThreadTask.java b/Aria/src/main/java/com/arialyy/aria/core/common/AbsThreadTask.java
index a432f581..bb4fe7be 100644
--- a/Aria/src/main/java/com/arialyy/aria/core/common/AbsThreadTask.java
+++ b/Aria/src/main/java/com/arialyy/aria/core/common/AbsThreadTask.java
@@ -455,7 +455,7 @@ public abstract class AbsThreadTask<ENTITY extends AbsNormalEntity, TASK_ENTITY
   }
 
   @Override public AbsThreadTask call() throws Exception {
-    isInterrupted = true;
+    isInterrupted = false;
     return this;
   }
 }
diff --git a/Aria/src/main/java/com/arialyy/aria/core/manager/ThreadTaskManager.java b/Aria/src/main/java/com/arialyy/aria/core/manager/ThreadTaskManager.java
index 5ae2d674..9efa6b15 100644
--- a/Aria/src/main/java/com/arialyy/aria/core/manager/ThreadTaskManager.java
+++ b/Aria/src/main/java/com/arialyy/aria/core/manager/ThreadTaskManager.java
@@ -81,7 +81,8 @@ public class ThreadTaskManager {
       ALog.e(TAG, "线程池已经关闭");
       return;
     }
-    Set<Future> temp = mThreadTasks.get(getKey(key));
+    key = getKey(key);
+    Set<Future> temp = mThreadTasks.get(key);
     try {
       for (Future future : temp) {
         if (future.isDone() || future.isCancelled()) {
diff --git a/README.md b/README.md
index b6c32dc9..e97d035f 100644
--- a/README.md
+++ b/README.md
@@ -32,8 +32,8 @@ Aria有以下特点：
 [![Download](https://api.bintray.com/packages/arialyy/maven/AriaApi/images/download.svg)](https://bintray.com/arialyy/maven/AriaApi/_latestVersion)
 [![Download](https://api.bintray.com/packages/arialyy/maven/AriaCompiler/images/download.svg)](https://bintray.com/arialyy/maven/AriaCompiler/_latestVersion)
 ```java
-compile 'com.arialyy.aria:aria-core:3.4.15'
-annotationProcessor 'com.arialyy.aria:aria-compiler:3.4.15'
+compile 'com.arialyy.aria:aria-core:3.4.16'
+annotationProcessor 'com.arialyy.aria:aria-compiler:3.4.16'
 ```
 如果出现android support，请将 `compile 'com.arialyy.aria:aria-core:<last-version>'`替换为
 ```
diff --git a/build.gradle b/build.gradle
index 33bd13cb..ed1e5bf9 100644
--- a/build.gradle
+++ b/build.gradle
@@ -39,7 +39,7 @@ task clean(type: Delete) {
 ext {
   userOrg = 'arialyy'
   groupId = 'com.arialyy.aria'
-  publishVersion = '3.4.15'
+  publishVersion = '3.4.16'
 //  publishVersion = '1.0.3'  //FTP插件
   repoName='maven'
   desc = 'android 下载框架'