From 33df0fa017ca2c47da72c3c9ae7ad486ab7c353d Mon Sep 17 00:00:00 2001 From: slhafzjw Date: Thu, 5 Feb 2026 16:53:38 +0800 Subject: [PATCH] test(ActionExecutor): test with virtual thread pool support --- .../action/dispatcher/executor/ActionExecutorTest.java | 10 +++++----- 1 file changed, 5 insertions(+), 5 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 9d8e90a1..7227e982 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 @@ -164,17 +164,17 @@ class ActionExecutorTest { // 场景5:B4.2。目的:验证 IO 行动使用虚拟线程池。 @Test void execute_ioMetaAction_usesVirtualExecutor() { - ExecutorService directExecutor = new DirectExecutorService(); - ExecutorService virtualExecutor = Executors.newSingleThreadExecutor(); - stubExecutors(directExecutor, virtualExecutor); + ExecutorService platformExecutor = Executors.newFixedThreadPool(4); + ExecutorService virtualExecutor = Executors.newVirtualThreadPerTaskExecutor(); + stubExecutors(platformExecutor, virtualExecutor); ImmediateActionData actionData = buildActionData(singleStageChain(true)); ActionExecutorInput input = buildInput("u1", actionData); ExtractorResult extractorResult = new ExtractorResult(); extractorResult.setOk(true); - when(paramsExtractor.execute(any())).thenReturn(extractorResult); - doAnswer(inv -> { + lenient().when(paramsExtractor.execute(any())).thenReturn(extractorResult); + lenient().doAnswer(inv -> { MetaAction metaAction = inv.getArgument(0); metaAction.getResult().setStatus(MetaAction.ResultStatus.SUCCESS); return null;