From 57f99fec8c71989f78986b52338adaff857d2767 Mon Sep 17 00:00:00 2001
From: zhaohe <h_zhaohe@163.com>
Date: Mon, 15 Jul 2024 15:01:04 +0800
Subject: [PATCH] add A8kDebugTaskExecutorService

---
 src/main/java/a8k/appbean/DebugTask.java           |  9 -----
 src/main/java/a8k/appbean/DebugTaskContext.java    | 19 ----------
 .../a8k/service/A8kDebugTaskExecutorService.java   | 43 ++++++++++++++++++++++
 src/main/java/a8k/service/A8kStateMgrService.java  |  9 +++++
 .../a8k/service/DebugTaskSchedulerService.java     | 16 --------
 5 files changed, 52 insertions(+), 44 deletions(-)
 delete mode 100644 src/main/java/a8k/appbean/DebugTask.java
 delete mode 100644 src/main/java/a8k/appbean/DebugTaskContext.java
 create mode 100644 src/main/java/a8k/service/A8kDebugTaskExecutorService.java
 create mode 100644 src/main/java/a8k/service/A8kStateMgrService.java
 delete mode 100644 src/main/java/a8k/service/DebugTaskSchedulerService.java

diff --git a/src/main/java/a8k/appbean/DebugTask.java b/src/main/java/a8k/appbean/DebugTask.java
deleted file mode 100644
index e597bdb..0000000
--- a/src/main/java/a8k/appbean/DebugTask.java
+++ /dev/null
@@ -1,9 +0,0 @@
-package a8k.appbean;
-
-public interface DebugTask {
-	public void run(DebugTaskContext cxt);
-
-	public void onStop(DebugTaskContext cxt);
-
-	public void onException(DebugTaskContext cxt, Exception e);
-}
diff --git a/src/main/java/a8k/appbean/DebugTaskContext.java b/src/main/java/a8k/appbean/DebugTaskContext.java
deleted file mode 100644
index 0c23e6c..0000000
--- a/src/main/java/a8k/appbean/DebugTaskContext.java
+++ /dev/null
@@ -1,19 +0,0 @@
-package a8k.appbean;
-
-import java.util.HashMap;
-import java.util.Map;
-
-public class DebugTaskContext {
-
-	Map<String, Object> vals = new HashMap<>();
-
-
-	void setContext(String key, Object val) {
-		vals.put(key, val);
-	}
-
-
-	public <T> T getContext(String key) {
-		return (T) vals.get(key);
-	}
-}
diff --git a/src/main/java/a8k/service/A8kDebugTaskExecutorService.java b/src/main/java/a8k/service/A8kDebugTaskExecutorService.java
new file mode 100644
index 0000000..9603e1e
--- /dev/null
+++ b/src/main/java/a8k/service/A8kDebugTaskExecutorService.java
@@ -0,0 +1,43 @@
+package a8k.service;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.stereotype.Component;
+
+@Component
+public class A8kDebugTaskExecutorService {
+	public static final Logger logger = LoggerFactory.getLogger(A8kDebugTaskExecutorService.class);
+
+	Thread task;
+
+	synchronized void  exec(Runnable runnable) {
+		if (task != null) {
+			task.interrupt();
+			try {
+				task.join();
+			} catch (InterruptedException ignored) {
+				return;
+			}
+		}
+
+		task = new Thread(runnable);
+		task.start();
+	}
+
+	synchronized void stop() {
+		try {
+			task.join();
+			task = null;
+		} catch (InterruptedException e) {
+			logger.error(e.getMessage());
+		}
+	}
+
+	synchronized boolean isRunning() {
+		if (task == null) {
+			return false;
+		}
+		return task.isAlive();
+	}
+
+}
diff --git a/src/main/java/a8k/service/A8kStateMgrService.java b/src/main/java/a8k/service/A8kStateMgrService.java
new file mode 100644
index 0000000..74eb508
--- /dev/null
+++ b/src/main/java/a8k/service/A8kStateMgrService.java
@@ -0,0 +1,9 @@
+package a8k.service;
+
+import org.springframework.stereotype.Component;
+
+@Component
+public class A8kStateMgrService {
+
+
+}
diff --git a/src/main/java/a8k/service/DebugTaskSchedulerService.java b/src/main/java/a8k/service/DebugTaskSchedulerService.java
deleted file mode 100644
index 868efe4..0000000
--- a/src/main/java/a8k/service/DebugTaskSchedulerService.java
+++ /dev/null
@@ -1,16 +0,0 @@
-package a8k.service;
-
-
-
-public class DebugTaskSchedulerService {
-
-
-
-	public void stop(){
-
-	}
-
-	public void start(){
-
-	}
-}