From 4b2bbdeb86cc019fdd2e8566f09feee1aec06a8f Mon Sep 17 00:00:00 2001
From: Odboy <tianjun@odboy.cn>
Date: Wed, 16 Apr 2025 21:00:45 +0800
Subject: [PATCH] =?UTF-8?q?upd:=20=E6=9A=B4=E5=8A=9B=E5=81=9C=E6=AD=A2?=
 =?UTF-8?q?=E7=BA=BF=E7=A8=8B?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../src/main/java/cn/odboy/context/PipelineManage.java      | 6 +-----
 .../src/main/java/cn/odboy/context/PipelineTaskPool.java    | 4 +++-
 2 files changed, 4 insertions(+), 6 deletions(-)

diff --git a/cutejava/cutejava-pipline/src/main/java/cn/odboy/context/PipelineManage.java b/cutejava/cutejava-pipline/src/main/java/cn/odboy/context/PipelineManage.java
index e411a526..217bb484 100644
--- a/cutejava/cutejava-pipline/src/main/java/cn/odboy/context/PipelineManage.java
+++ b/cutejava/cutejava-pipline/src/main/java/cn/odboy/context/PipelineManage.java
@@ -26,12 +26,8 @@ public class PipelineManage {
         pipelineTaskPool.submitTask(pipelineId, () -> {
             List<PipelineNodeVo> pipelineNodeVos = initialize();
             for (PipelineNodeVo pipelineNodeVo : pipelineNodeVos) {
-                if (Thread.currentThread().isInterrupted()) {
-                    log.info("流水线被强行终止...");
-                    break;
-                }
                 executePipeline(pipelineId, pipelineNodeVo);
-                while (!Thread.currentThread().isInterrupted() && "running".equals(pipelineNodeVo.getExecuteStatus())) {
+                while ("running".equals(pipelineNodeVo.getExecuteStatus())) {
                     log.info("流水线执行中...");
                     ThreadUtil.safeSleep(2000);
                 }
diff --git a/cutejava/cutejava-pipline/src/main/java/cn/odboy/context/PipelineTaskPool.java b/cutejava/cutejava-pipline/src/main/java/cn/odboy/context/PipelineTaskPool.java
index f9d93cbe..5dfab0f1 100644
--- a/cutejava/cutejava-pipline/src/main/java/cn/odboy/context/PipelineTaskPool.java
+++ b/cutejava/cutejava-pipline/src/main/java/cn/odboy/context/PipelineTaskPool.java
@@ -216,7 +216,9 @@ public class PipelineTaskPool {
 
             if (running.compareAndSet(true, false)) {
                 if (currentThread != null) {
-                    currentThread.interrupt();
+//                    currentThread.interrupt();
+                    // 暴力停止线程
+                    currentThread.stop();
                 }
                 return true;
             }