feat: 前端请求并发控制重构，优化订阅 flow 拉取中断与重试行为

- 新增 `src/utils/requestConcurrency.ts`，统一管理前端请求队列、并发上限（默认 3）和可配置等待时间（`concurrencyWaitTime`），并支持优先级与 `AbortSignal` 取消。
- `useSubsStore` 中重构 `fetchFlows`：新增 per-flow 版本号 + abort 控制，增加重复触发和页面切换时的旧请求拦截，移除旧的 `executeAsyncTasks` 实现。
- 路由和请求端联动：离开 `/subs` 时自动取消未完成 flow 请求；`getFlow` 增加 `signal` 参数并按新并发任务模型执行。
- 将 `subs`、`files`、`share`、`settings`、`archive`、`artifacts` 的关键请求改为 `runFrontendRequestTask`，减少竞态并统一行为。
- 新增 `concurrencyWaitTime` 配置链路：支持 URL query 参数写入、My 页面配置项、提示文案，并同步更新中英文+俄文文案。
- `My` 页面新增并发等待时间输入及说明弹窗，界面可视化配置该参数。

Author: xream

src/api/subs/index.ts

@@ -28,10 +28,11 @@ export function useSubsApi() {
         method: 'get',
       });
     },
-    getFlow: (name: string): AxiosPromise<MyAxiosRes> => {
+    getFlow: (name: string, signal?: AbortSignal): AxiosPromise<MyAxiosRes> => {
       return request({
         url: `/api/sub/flow/${encodeURIComponent(name)}`,
         method: 'get',
+        signal,
       });
     },
     getSubInfo: (data: NodeInfo): AxiosPromise<MyAxiosRes> => {

src/hooks/useHostAPI.ts

@@ -194,6 +194,24 @@ export const useHostAPI = () => {
         }
       }
     }
+    // 处理 concurrencyWaitTime 参数
+    const concurrencyWaitTime = query
+      .slice(1)
+      .split('&')
+      .map(i => i.split('='))
+      .find(i => i[0] === 'concurrencyWaitTime');
+    if (concurrencyWaitTime) {
+      const value = parseInt(concurrencyWaitTime[1], 10);
+      if (!isNaN(value)) {
+        if (value > 0) {
+          console.log(`设置并发等待时间 ${value}`)
+          localStorage.setItem('concurrencyWaitTime', value.toString());
+        } else {
+          console.log(`清除并发等待时间设置`)
+          localStorage.removeItem('concurrencyWaitTime');
+        }
+      }
+    }
     // 处理 timeout 参数
     const timeout = query
       .slice(1)

src/locales/en.ts

@@ -736,6 +736,7 @@ export default {
       scriptCacheTtl: 'Script Cache TTL, default: 172800(s)',
       logsMaxCount: 'Max stored logs, default: 0=off',
       concurrency: 'Concurrency Limit(default: 3)',
+      concurrencyWaitTime: 'Concurrency Wait Time, default: 0(ms)',
       apiCheckTimeout: 'API Check Timeout, default: 3000(ms)',
       apiRequestTimeout: 'Front-End Request Timeout, default: 50000(ms)',
       noGithubUser: "Not set GitHub username",

src/locales/ru.ts

@@ -785,6 +785,7 @@ export default {
       "scriptCacheTtl": "TTL кэша скриптов, по умолчанию: 172800 (сек)",
       "logsMaxCount": "Макс. количество логов, 0 = отключено",
       "concurrency": "Лимит параллельных запросов (по умолчанию: 3)",
+      "concurrencyWaitTime": "Время ожидания параллельных запросов, по умолчанию: 0 (мс)",
       "apiCheckTimeout": "Таймаут проверки API, по умолчанию: 3000 (мс)",
       "apiRequestTimeout": "Таймаут запросов интерфейса, по умолчанию: 50000 (мс)",
       "noGithubUser": "Не задано имя пользователя GitHub",

src/locales/zh.ts

@@ -700,6 +700,7 @@ export default {
       scriptCacheTtl: '脚本缓存(单位: 秒, 默认: 172800)',
       logsMaxCount: '最大保存日志条数(默认: 0=关闭)',
       concurrency: '并发数(默认: 3)',
+      concurrencyWaitTime: '并发等待时间(单位: 毫秒, 默认: 0)',
       apiCheckTimeout: 'API 检测超时(单位: 毫秒, 默认: 3000)',
       apiRequestTimeout: '前端请求超时(单位: 毫秒, 默认: 50000)',
       noGithubUser: '未配置 GitHub 用户名',

src/router/index.ts

@@ -5,6 +5,7 @@ import { useFilesApi } from '@/api/files';
 
 import AppLayout from '@/layout/AppLayout.vue';
 import { useGlobalStore } from '@/store/global';
+import { useSubsStore } from '@/store/subs';
 import { initStores } from '@/utils/initApp';
 import My from '@/views/My.vue';
 
@@ -335,6 +336,9 @@ router.afterEach(async (to, from) => {
 router.beforeEach((to, from) => {
   document.title = 'Sub Store';
   // console.log(`beforeEach ${from.path} => ${to.path}`)
+  if (to?.path !== '/subs') {
+    useSubsStore().cancelFetchFlows();
+  }
   if (!globalStore) {
     globalStore = useGlobalStore();
   }

src/store/archive.ts

@@ -6,6 +6,7 @@ import { useAppNotifyStore } from '@/store/appNotify';
 import { useArtifactsStore } from '@/store/artifacts';
 import { useSubsStore } from '@/store/subs';
 import { normalizeArchiveEntry } from '@/utils/archive';
+import { runFrontendRequestTask } from '@/utils/requestConcurrency';
 
 const archiveApi = useArchiveApi();
 const { t } = i18n.global;
@@ -22,7 +23,7 @@ export const useArchiveStore = defineStore('archiveStore', {
   actions: {
     async fetchEntries() {
       try {
-        const res = await archiveApi.getEntries();
+        const res = await runFrontendRequestTask(() => archiveApi.getEntries(), 'archive.getEntries');
         if (res?.data?.status === 'success') {
           this.entries = (res.data.data || []).map(normalizeArchiveEntry);
           return true;

src/store/artifacts.ts

@@ -1,6 +1,7 @@
 import { useArtifactsApi } from '@/api/artifacts';
 import i18n from '@/locales';
 import { useAppNotifyStore } from '@/store/appNotify';
+import { runFrontendRequestTask } from '@/utils/requestConcurrency';
 import { defineStore } from 'pinia';
 
 const { t } = i18n.global;
@@ -15,7 +16,7 @@ export const useArtifactsStore = defineStore('artifactsStore', {
   getters: {},
   actions: {
     async fetchArtifactsData() {
-      const { data } = await artifactsApi.getArtifacts();
+      const { data } = await runFrontendRequestTask(() => artifactsApi.getArtifacts(), 'artifacts.getArtifacts');
       if (data.status === 'success') {
         this.artifacts = data.data;
       }

src/store/settings.ts

@@ -2,6 +2,7 @@ import { useSettingsApi } from "@/api/settings";
 import i18n from "@/locales";
 import { useGlobalStore } from '@/store/global';
 import { useAppNotifyStore } from "@/store/appNotify";
+import { runFrontendRequestTask } from "@/utils/requestConcurrency";
 import { Toast } from "@nutui/nutui";
 import { defineStore } from "pinia";
 // import { useEnvApi } from '@/api/env';
@@ -197,7 +198,7 @@ export const useSettingsStore = defineStore("settingsStore", {
     },
     async fetchSettings() {
       const { showNotify } = useAppNotifyStore();
-      const res = await settingsApi.getSettings();
+      const res = await runFrontendRequestTask(() => settingsApi.getSettings(), "settings.getSettings");
       if (res?.data?.status === "success" && res?.data?.data) {
         this.syncPlatform = res.data.data.syncPlatform || "";
         this.gistToken = res.data.data.gistToken || "";