From ed4c2c4b6f60c354806b8a6f8f1c0665dc4c4e6c Mon Sep 17 00:00:00 2001
From: AriaLyy <511455842@qq.com>
Date: Wed, 15 Nov 2017 20:09:58 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D3.3.7=5Fdev=20=E4=BB=BB?=
 =?UTF-8?q?=E5=8A=A1=E7=BB=84=E6=9A=82=E5=81=9C=E6=B2=A1=E5=8F=8D=E5=BA=94?=
 =?UTF-8?q?=E7=9A=84=E9=97=AE=E9=A2=98=20https://github.com/AriaLyy/Aria/i?=
 =?UTF-8?q?ssues/164?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../com/arialyy/aria/core/common/AbsFileer.java     |  7 +++++--
 .../core/download/downloader/HttpThreadTask.java    | 13 +++++++++----
 app/src/main/assets/aria_config.xml                 |  2 +-
 3 files changed, 15 insertions(+), 7 deletions(-)

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 c6066e96..78c0fe71 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
@@ -122,8 +122,11 @@ public abstract class AbsFileer<ENTITY extends AbsNormalEntity, TASK_ENTITY exte
    * 设置新任务的最大线程数
    */
   protected int getNewTaskThreadNum() {
-    return mEntity.getFileSize() <= SUB_LEN || mTaskEntity.requestType == AbsTaskEntity.D_FTP_DIR
-        ? 1 : AriaManager.getInstance(mContext).getDownloadConfig().getThreadNum();
+    final int num =
+        mEntity.getFileSize() <= SUB_LEN || mTaskEntity.requestType == AbsTaskEntity.D_FTP_DIR ? 1
+            : AriaManager.getInstance(mContext).getDownloadConfig().getThreadNum();
+    mStartThreadNum = num;
+    return num;
   }
 
   /**
diff --git a/Aria/src/main/java/com/arialyy/aria/core/download/downloader/HttpThreadTask.java b/Aria/src/main/java/com/arialyy/aria/core/download/downloader/HttpThreadTask.java
index 3153d504..8b6f09c5 100644
--- a/Aria/src/main/java/com/arialyy/aria/core/download/downloader/HttpThreadTask.java
+++ b/Aria/src/main/java/com/arialyy/aria/core/download/downloader/HttpThreadTask.java
@@ -80,13 +80,18 @@ final class HttpThreadTask extends AbsThreadTask<DownloadEntity, DownloadTaskEnt
       byte[] buffer = new byte[mBufSize];
       int len;
       while ((len = is.read(buffer)) != -1) {
-        if (STATE.isCancel) break;
-        if (STATE.isStop) break;
-        if (mSleepTime > 0) Thread.sleep(mSleepTime);
+        if (STATE.isCancel || STATE.isStop){
+          break;
+        }
+        if (mSleepTime > 0) {
+          Thread.sleep(mSleepTime);
+        }
         file.write(buffer, 0, len);
         progress(len);
       }
-      if (STATE.isCancel || STATE.isStop) return;
+      if (STATE.isCancel || STATE.isStop){
+        return;
+      }
       //支持断点的处理
       if (mConfig.SUPPORT_BP) {
         ALog.i(TAG, "任务【" + mConfig.TEMP_FILE.getName() + "】线程__" + mConfig.THREAD_ID + "__下载完毕");
diff --git a/app/src/main/assets/aria_config.xml b/app/src/main/assets/aria_config.xml
index 92324c01..0220148e 100644
--- a/app/src/main/assets/aria_config.xml
+++ b/app/src/main/assets/aria_config.xml
@@ -8,7 +8,7 @@
     <threadNum value="3"/>
 
     <!--设置下载队列最大任务数， 默认为2-->
-    <maxTaskNum value="2"/>
+    <maxTaskNum value="1"/>
 
     <!--设置下载失败，重试次数，默认为10-->
     <reTryNum value="2"/>