From 2eaa74e032de02abefef0645b321e147d628a893 Mon Sep 17 00:00:00 2001 From: caihaohan Date: Fri, 20 Sep 2024 16:19:06 +0800 Subject: [PATCH] =?UTF-8?q?feat:=20=E5=8E=BB=E9=99=A4=E5=BC=82=E6=AD=A5?= =?UTF-8?q?=E5=8F=91=E9=80=81=E5=BE=85=E5=8A=9E?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../activiti/listener/MyGlobalEventListener.java | 15 ++------------- 1 file changed, 2 insertions(+), 13 deletions(-) diff --git a/laws-modules/src/main/java/com/jero/modules/activiti/listener/MyGlobalEventListener.java b/laws-modules/src/main/java/com/jero/modules/activiti/listener/MyGlobalEventListener.java index 8d0a817f..b8e7cc77 100644 --- a/laws-modules/src/main/java/com/jero/modules/activiti/listener/MyGlobalEventListener.java +++ b/laws-modules/src/main/java/com/jero/modules/activiti/listener/MyGlobalEventListener.java @@ -35,7 +35,6 @@ import java.util.*; import java.util.concurrent.CompletableFuture; import java.util.concurrent.Executors; import java.util.concurrent.ScheduledExecutorService; -import java.util.concurrent.TimeUnit; /** * @author liJiaRao @@ -173,12 +172,8 @@ public class MyGlobalEventListener implements ActivitiEventListener { hiworkTodoAdd.setRecordId(approvalRecord.getId()); hiworkTodoAdd.setProcessDefinitionId(processDefinitionId); list.add(hiworkTodoAdd); - ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(1); // 调度5秒后执行异步任务 - scheduler.schedule(() -> - CompletableFuture.runAsync(() -> pushWorkflowIntegrationAPI.sendTodoTask(list)), - 5, TimeUnit.SECONDS - ); + pushWorkflowIntegrationAPI.sendTodoTask(list); } private void taskAssigned(ActivitiEvent event) { @@ -306,13 +301,7 @@ public class MyGlobalEventListener implements ActivitiEventListener { hiworkTodoAdd.setRecordId(approvalRecord.getId()); hiworkTodoAdd.setProcessDefinitionId(processDefinitionId); list.add(hiworkTodoAdd); - // 异步发送待办 - ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(1); - // 调度5秒后执行异步任务 - scheduler.schedule(() -> - CompletableFuture.runAsync(() -> pushWorkflowIntegrationAPI.sendTodoTask(list)), - 5, TimeUnit.SECONDS - ); + CompletableFuture.runAsync(() -> pushWorkflowIntegrationAPI.sendTodoTask(list)); } private void entityDeleted(ActivitiEvent event) {