From 86df207c37502cce1b2043e1c7c0486459eef1d6 Mon Sep 17 00:00:00 2001
From: mitao <2763622819@qq.com>
Date: 星期四, 13 三月 2025 19:58:45 +0800
Subject: [PATCH] 党员、诉求评论基础代码
---
springcloud_k8s_panzhihuazhihuishequ/auth/src/main/java/com/panzhihua/auth/manager/AsyncManagerNew.java | 53 +++++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 53 insertions(+), 0 deletions(-)
diff --git a/springcloud_k8s_panzhihuazhihuishequ/auth/src/main/java/com/panzhihua/auth/manager/AsyncManagerNew.java b/springcloud_k8s_panzhihuazhihuishequ/auth/src/main/java/com/panzhihua/auth/manager/AsyncManagerNew.java
new file mode 100644
index 0000000..c1d0c33
--- /dev/null
+++ b/springcloud_k8s_panzhihuazhihuishequ/auth/src/main/java/com/panzhihua/auth/manager/AsyncManagerNew.java
@@ -0,0 +1,53 @@
+package com.panzhihua.auth.manager;
+
+import java.util.TimerTask;
+import java.util.concurrent.ScheduledExecutorService;
+import java.util.concurrent.TimeUnit;
+
+import com.panzhihua.common.utlis.SpringUtils;
+import com.panzhihua.common.utlis.Threads;
+
+/**
+ * @program: springcloud_k8s_panzhihuazhihuishequ
+ * @description: 异步任务
+ * @author: huang.hongfa weixin hhf9596 qq 959656820
+ * @create: 2020-11-20 15:30
+ **/
+public class AsyncManagerNew {
+
+ private static AsyncManagerNew me = new AsyncManagerNew();
+ /**
+ * 操作延迟10毫秒
+ */
+ private final int OPERATE_DELAY_TIME = 10;
+ /**
+ * 异步操作任务调度线程池
+ */
+ private ScheduledExecutorService executor = SpringUtils.getBean("scheduledExecutorService");
+
+ /**
+ * 单例模式
+ */
+ private AsyncManagerNew() {}
+
+ public static AsyncManagerNew me() {
+ return me;
+ }
+
+ /**
+ * 执行任务
+ *
+ * @param task
+ * 任务
+ */
+ public void execute(TimerTask task) {
+ executor.schedule(task, OPERATE_DELAY_TIME, TimeUnit.MILLISECONDS);
+ }
+
+ /**
+ * 停止任务线程池
+ */
+ public void shutdown() {
+ Threads.shutdownAndAwaitTermination(executor);
+ }
+}
--
Gitblit v1.7.1