fix #333

jeasonlzy · Jun 28, 2017 · 050801b · 050801b
1 parent e854793
commit 050801b
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 6 deletions.
diff --git a/demo/src/main/java/com/lzy/demo/okdownload/DownloadListActivity.java b/demo/src/main/java/com/lzy/demo/okdownload/DownloadListActivity.java
@@ -84,7 +84,7 @@ protected void onCreate(Bundle savedInstanceState) {
 
         initData();
         OkDownload.getInstance().setFolder(Environment.getExternalStorageDirectory().getAbsolutePath() + "/aaa/");
-        OkDownload.getInstance().getThreadPool().setCorePoolSize(1);
+        OkDownload.getInstance().getThreadPool().setCorePoolSize(3);
 
         folder.setText(String.format("下载路径: %s", OkDownload.getInstance().getFolder()));
         recyclerView.setLayoutManager(new LinearLayoutManager(this));

diff --git a/okserver/src/main/java/com/lzy/okserver/OkDownload.java b/okserver/src/main/java/com/lzy/okserver/OkDownload.java
@@ -29,9 +29,9 @@
 import java.io.File;
 import java.util.ArrayList;
 import java.util.HashMap;
-import java.util.LinkedHashMap;
 import java.util.List;
 import java.util.Map;
+import java.util.concurrent.ConcurrentHashMap;
 
 /**
  * ================================================
@@ -44,9 +44,9 @@
  */
 public class OkDownload {
 
-    private String folder;                      //下载的默认文件夹
-    private DownloadThreadPool threadPool;      //下载的线程池
-    private Map<String, DownloadTask> taskMap;  //所有任务
+    private String folder;                                      //下载的默认文件夹
+    private DownloadThreadPool threadPool;                      //下载的线程池
+    private ConcurrentHashMap<String, DownloadTask> taskMap;    //所有任务
 
     public static OkDownload getInstance() {
         return OkDownloadHolder.instance;
@@ -60,7 +60,7 @@ private OkDownload() {
         folder = Environment.getExternalStorageDirectory() + File.separator + "download" + File.separator;
         IOUtils.createFolder(folder);
         threadPool = new DownloadThreadPool();
-        taskMap = new LinkedHashMap<>();
+        taskMap = new ConcurrentHashMap<>();
 
         //校验数据的有效性，防止下载过程中退出，第二次进入的时候，由于状态没有更新导致的状态错误
         List<Progress> taskList = DownloadManager.getInstance().getDownloading();