优化修改定时任务时的停止速度

wushuo894 · Oct 15, 2024 · 25716a7 · 25716a7
1 parent 3834305
commit 25716a7
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 5 deletions.
diff --git a/src/main/java/ani/rss/task/BgmTask.java b/src/main/java/ani/rss/task/BgmTask.java
@@ -33,6 +33,9 @@ public void run() {
                 if (StrUtil.isBlank(bgmUrl)) {
                     continue;
                 }
+                if (!loop.get()) {
+                    return;
+                }
                 Boolean enable = ani.getEnable();
                 double score = ani.getScore();
                 if (enable || score < 1) {

diff --git a/src/main/java/ani/rss/task/RenameTask.java b/src/main/java/ani/rss/task/RenameTask.java
@@ -2,17 +2,13 @@
 
 import ani.rss.entity.Config;
 import ani.rss.entity.TorrentsInfo;
-import ani.rss.enums.MessageEnum;
 import ani.rss.util.ConfigUtil;
 import ani.rss.util.ExceptionUtil;
-import ani.rss.util.MessageUtil;
 import ani.rss.util.TorrentUtil;
 import cn.hutool.core.thread.ThreadUtil;
-import cn.hutool.core.util.StrUtil;
 import lombok.extern.slf4j.Slf4j;
 
 import java.util.List;
-import java.util.Objects;
 import java.util.concurrent.TimeUnit;
 import java.util.concurrent.atomic.AtomicBoolean;
 
@@ -40,6 +36,9 @@ public void run() {
             try {
                 List<TorrentsInfo> torrentsInfos = TorrentUtil.getTorrentsInfos();
                 for (TorrentsInfo torrentsInfo : torrentsInfos) {
+                    if (!loop.get()) {
+                        return;
+                    }
                     TorrentUtil.rename(torrentsInfo);
                     TorrentUtil.notification(torrentsInfo);
                     TorrentUtil.delete(torrentsInfo);

diff --git a/src/main/java/ani/rss/util/TaskUtil.java b/src/main/java/ani/rss/util/TaskUtil.java
@@ -22,7 +22,7 @@ public static synchronized void stop() {
                 // 等待现有任务结束
                 while (thread.isAlive()) {
                     thread.interrupt();
-                    ThreadUtil.sleep(500);
+                    ThreadUtil.sleep(100);
                 }
                 thread.join();
             } catch (Exception e) {