diff --git a/Partner-Main/src/main/java/work/slhaf/partner/module/modules/action/dispatcher/executor/ActionExecutor.java b/Partner-Main/src/main/java/work/slhaf/partner/module/modules/action/dispatcher/executor/ActionExecutor.java index 07cdc8d4..a74d5f69 100644 --- a/Partner-Main/src/main/java/work/slhaf/partner/module/modules/action/dispatcher/executor/ActionExecutor.java +++ b/Partner-Main/src/main/java/work/slhaf/partner/module/modules/action/dispatcher/executor/ActionExecutor.java @@ -18,7 +18,6 @@ import work.slhaf.partner.module.modules.action.dispatcher.executor.entity.*; import java.util.ArrayList; import java.util.List; -import java.util.Map; import java.util.concurrent.CountDownLatch; import java.util.concurrent.ExecutorService; import java.util.concurrent.Phaser; @@ -72,6 +71,12 @@ public class ActionExecutor extends AgentRunningSubModule> actionChain = actionData.getActionChain(); int stageCount; boolean executingStageUpdated; boolean stageCountUpdated; @@ -118,7 +122,6 @@ public class ActionExecutor extends AgentRunningSubModule()); ActionExecutorInput input = buildInput("u1", actionData); @@ -355,7 +356,10 @@ class ActionExecutorTest { actionExecutor.init(); actionExecutor.execute(input); - verify(actionCapability, never()).removePhaserRecord(any(Phaser.class)); + try { + Thread.sleep(500); + } catch (InterruptedException ignored) { + } } private void stubExecutors(ExecutorService platformExecutor, ExecutorService virtualExecutor) {