feat: 支持使用 query 参数 concurrency 设置并发数, <=0 则为清除自定义设置, 默认为 3. 若因并发导致爆内存, 可设为 1

Author: xream

package.json

@@ -1,6 +1,6 @@
 {
   "name": "sub-store-front-end",
-  "version": "2.15.82",
+  "version": "2.15.83",
   "private": true,
   "scripts": {
     "dev": "vite --host",

src/hooks/useHostAPI.ts

@@ -148,6 +148,25 @@ export const useHostAPI = () => {
       return false; // 没有URL参数，返回false
     }
 
+    // 处理 concurrency 参数
+    const concurrency = query
+      .slice(1)
+      .split('&')
+      .map(i => i.split('='))
+      .find(i => i[0] === 'concurrency');
+    if (concurrency) {
+      const value = parseInt(concurrency[1], 10);
+      if (!isNaN(value)) {
+        if (value >= 1) {
+          console.log(`设置并发数 ${value}`)
+          localStorage.setItem('concurrency', value.toString());
+        } else {
+          console.log(`清除并发数设置`)
+          localStorage.removeItem('concurrency');
+        }
+      }
+    }
+
     // 处理api参数
     const apiUrl = query
       .slice(1)

src/store/subs.ts

@@ -309,7 +309,7 @@ export const useSubsStore = defineStore('subsStore', {
 
       await executeAsyncTasks(
         flowsUrlList.map((item, index) => () =>  asyncGetFlow(item, index)),
-        { concurrency: 3 }
+        { concurrency: localStorage.getItem('concurrency') ? parseInt(localStorage.getItem('concurrency') as string, 10) : 3 }
       )
 
       // const batches = [];