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

fix(ActionExecutor): correct phaser block logic in method execute

Browse Source
This commit is contained in:
slhafzjw
2026-01-28 15:38:13 +08:00
parent 5ffdab9e4a
commit cd641ac8dd
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
Partner-Main/src/main/java/work/slhaf/partner/module/modules/action/dispatcher/executor/ActionExecutor.java
View File

@@ -85,11 +85,12 @@ public class ActionExecutor extends AgentRunningSubModule<ActionExecutorInput, V
actionData.setExecutingStage(executingStage); actionData.setExecutingStage(executingStage);
val metaActions = actionChain.get(executingStage); val metaActions = actionChain.get(executingStage);
phaser.bulkRegister(metaActions.size()); val phase = phaser.bulkRegister(metaActions.size());
for (MetaAction metaAction : metaActions) { for (MetaAction metaAction : metaActions) {
val executor = metaAction.isIo() ? virtualExecutor : platformExecutor; val executor = metaAction.isIo() ? virtualExecutor : platformExecutor;
executor.execute(buildMataActionTask(metaAction, phaserRecord, userId)); executor.execute(buildMataActionTask(metaAction, phaserRecord, userId));
} }
phaser.awaitAdvance(phase);
// TODO 进行行动链修正 // TODO 进行行动链修正
val correctorInput = assemblyHelper.buildCorrectorInput(); val correctorInput = assemblyHelper.buildCorrectorInput();