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

新增 SandboxRunner 项目子模块，该模块将在指定容器运行持久服务，与外部主进程通信，将用于后续执行JAR、SCRIPT两类行动类型

Browse Source
This commit is contained in:
slhafzjw
2025-11-30 18:41:42 +08:00
parent b3098310b4
commit c548cceec6
15 changed files with 663 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
Partner-Main/src/main/java/work/slhaf/partner/core/action/entity/ActionData.java
View File

@@ -53,6 +53,21 @@ public abstract class ActionData {
protected String source;
public enum ActionStatus {
SUCCESS, FAILED, EXECUTING, PREPARE
/**
* 执行成功
*/
SUCCESS,
/**
* 执行失败
*/
FAILED,
/**
* 执行中
*/
EXECUTING,
/**
* 预备执行
*/
PREPARE
}
}

7
Partner-Main/src/main/java/work/slhaf/partner/module/modules/action/dispatcher/ActionDispatcher.java
View File

@@ -4,8 +4,8 @@ import work.slhaf.partner.api.agent.factory.capability.annotation.InjectCapabili
import work.slhaf.partner.api.agent.factory.module.annotation.AgentModule;
import work.slhaf.partner.api.agent.factory.module.annotation.Init;
import work.slhaf.partner.api.agent.factory.module.annotation.InjectModule;
import work.slhaf.partner.common.thread.InteractionThreadPoolExecutor;
import work.slhaf.partner.core.action.ActionCapability;
import work.slhaf.partner.core.action.ActionCore;
import work.slhaf.partner.core.action.entity.ActionData;
import work.slhaf.partner.core.action.entity.ImmediateActionData;
import work.slhaf.partner.core.action.entity.ScheduledActionData;
@@ -16,6 +16,7 @@ import work.slhaf.partner.runtime.interaction.data.context.PartnerRunningFlowCon
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.ExecutorService;
@AgentModule(name = "action_dispatcher", order = 7)
public class ActionDispatcher extends PostRunningModule {
@@ -28,11 +29,11 @@ public class ActionDispatcher extends PostRunningModule {
@InjectModule
private ActionScheduler actionScheduler;
private InteractionThreadPoolExecutor executor;
private ExecutorService executor;
@Init
public void init() {
executor = InteractionThreadPoolExecutor.getInstance();
executor = actionCapability.getExecutor(ActionCore.ExecutorType.VIRTUAL);
}
@Override

2
Partner-Main/src/main/java/work/slhaf/partner/module/modules/action/planner/confirmer/ActionConfirmer.java
View File

@@ -59,7 +59,7 @@ public class ActionConfirmer extends AgentRunningSubModule<ConfirmerInput, Confi
} catch (InterruptedException e) {
log.warn("CountDownLatch阻塞已中断");
}
return null;
return result;
}
private String buildPrompt(ActionData data, String input, List<Message> recentMessages) {