slhaf/Partner
1
0
Fork 0
mirror of https://github.com/slhaf/Partner.git synced 2026-05-12 16:53:04 +08:00
Code Issues Packages Projects Releases Wiki Activity

test(ActionExecutor): test with virtual thread pool support

Browse Source
This commit is contained in:
slhafzjw
2026-02-05 16:53:38 +08:00
parent 08bda84471
commit 33df0fa017
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
Partner-Main/src/test/java/work/slhaf/partner/module/modules/action/dispatcher/executor/ActionExecutorTest.java
View File

@@ -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;