From 9c387195145dcea10d050bd46b61df35e60a8d01 Mon Sep 17 00:00:00 2001 From: slhafzjw Date: Thu, 5 Feb 2026 16:58:22 +0800 Subject: [PATCH] test(ActionExecutor): test with additionalContext appending --- .../dispatcher/executor/ActionExecutorTest.java | 11 ++++++++--- 1 file changed, 8 insertions(+), 3 deletions(-) diff --git a/Partner-Main/src/test/java/work/slhaf/partner/module/modules/action/dispatcher/executor/ActionExecutorTest.java b/Partner-Main/src/test/java/work/slhaf/partner/module/modules/action/dispatcher/executor/ActionExecutorTest.java index 7227e982..f641c904 100644 --- a/Partner-Main/src/test/java/work/slhaf/partner/module/modules/action/dispatcher/executor/ActionExecutorTest.java +++ b/Partner-Main/src/test/java/work/slhaf/partner/module/modules/action/dispatcher/executor/ActionExecutorTest.java @@ -190,8 +190,9 @@ class ActionExecutorTest { // 场景6：B7.2(失败) -> repairer OK -> B7(成功)。目的：验证修复后成功与上下文追加。 @Test void execute_extractorFail_thenRepairOk_thenSuccess() { - ExecutorService directExecutor = new DirectExecutorService(); - stubExecutors(directExecutor, directExecutor); + ExecutorService platformExecutor = Executors.newFixedThreadPool(4); + ExecutorService virtualExecutor = Executors.newVirtualThreadPerTaskExecutor(); + stubExecutors(platformExecutor, virtualExecutor); ImmediateActionData actionData = buildActionData(singleStageChain(false)); ActionExecutorInput input = buildInput("u1", actionData); @@ -216,8 +217,12 @@ class ActionExecutorTest { actionExecutor.init(); actionExecutor.execute(input); + try { + Thread.sleep(500); + } catch (InterruptedException ignored) { + } assertEquals(1, actionData.getAdditionalContext().get(0).size()); - verify(runnerClient, times(1)).submit(any(MetaAction.class)); + verify(runnerClient, timeout(5000).times(1)).submit(any(MetaAction.class)); } // 场景7：B7.2(失败) -> repairer FAILED。目的：验证失败分支不提交外部执行。