feat(core): Support multi-thread download

Author: 502y

src/main/java/i18nupdatemod/I18nUpdateMod.java

@@ -18,6 +18,10 @@
 import java.util.ArrayList;
 import java.util.List;
 import java.util.Objects;
+import java.util.concurrent.ExecutionException;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+import java.util.concurrent.Future;
 import java.util.stream.Collectors;
 import java.util.stream.Stream;
 
@@ -63,14 +67,31 @@ public static void init(Path minecraftPath, String minecraftVersion, String load
             List<ResourcePack> languagePacks = new ArrayList<>();
             boolean convertNotNeed = assets.downloads.size() == 1 && assets.downloads.get(0).targetVersion.equals(minecraftVersion);
             String applyFileName = assets.downloads.get(0).fileName;
-            for (GameAssetDetail.AssetDownloadDetail it : assets.downloads) {
-                FileUtil.setTemporaryDirPath(Paths.get(localStorage, "." + MOD_ID, it.targetVersion));
-                ResourcePack languagePack = new ResourcePack(it.fileName, convertNotNeed);
-                languagePack.checkUpdate(it.fileUrl, it.md5Url);
-                languagePacks.add(languagePack);
+            ExecutorService executor = Executors.newFixedThreadPool(assets.downloads.size());
+            try {
+                List<Future<?>> futures = new ArrayList<>();
+                for (GameAssetDetail.AssetDownloadDetail it : assets.downloads) {
+                    futures.add(executor.submit(() -> {
+                        FileUtil.setTemporaryDirPath(Paths.get(localStorage, "." + MOD_ID, it.targetVersion));
+                        ResourcePack languagePack = new ResourcePack(it.fileName, convertNotNeed);
+                        try {
+                            languagePack.checkUpdate(it.fileUrl, it.md5Url);
+                        } catch (Exception e) {
+                            Log.debug(String.format("Error while checking update for resource pack: %s", e));
+                        }
+                        languagePacks.add(languagePack);
+                    }));
+                }
+                for (Future<?> future : futures) {
+                    try {
+                        future.get();
+                    } catch (InterruptedException | ExecutionException e) {
+                        Log.debug(String.format("Error while updating resource pack: %s", e));
+                    }
+                }
+            } finally {
+                executor.shutdown();
             }
-
-            //Convert resourcepack
             if (!convertNotNeed) {
                 FileUtil.setTemporaryDirPath(Paths.get(localStorage, "." + MOD_ID, minecraftVersion));
                 applyFileName = assets.covertFileName;

src/main/java/i18nupdatemod/core/ResourcePack.java

@@ -39,14 +39,25 @@ public ResourcePack(String filename, boolean saveToGame) {
         }
     }
 
-    public void checkUpdate(String fileUrl, String md5Url) throws IOException, URISyntaxException, NoSuchAlgorithmException {
+    public void checkUpdate(String fileUrl, String md5Url) throws IOException, NoSuchAlgorithmException, URISyntaxException {
         if (isUpToDate(md5Url)) {
             Log.debug("Already up to date.");
             return;
         }
-        //In this time, we can only download full file
-        downloadFull(fileUrl, md5Url);
-        //In the future, we will download patch file and merge local file
+        int retryCount = 3;
+        while (retryCount > 0) {
+            try {
+                downloadFile(fileUrl, md5Url);
+                return;
+            } catch (Exception e) {
+                retryCount--;
+                if (retryCount == 0) {
+                    Log.debug(String.format("Failed to download resource pack at %s after 3 attempts: %s", fileUrl, e.getMessage()));
+                    Log.warning("Failed to download resource pack.");
+                    return;
+                }
+            }
+        }
     }
 
     private boolean isUpToDate(String md5Url) throws IOException, URISyntaxException, NoSuchAlgorithmException {
@@ -74,7 +85,7 @@ private boolean checkMd5(Path localFile, String md5Url) throws IOException, URIS
         return localMd5.equalsIgnoreCase(remoteMd5);
     }
 
-    private void downloadFull(String fileUrl, String md5Url) throws IOException {
+    private void downloadFile(String fileUrl, String md5Url) throws IOException {
         try {
             Path downloadTmp = FileUtil.getTemporaryPath(filename + ".tmp");
             AssetUtil.download(fileUrl, downloadTmp);