Function NewActorEngine

pkg/workflow/actor_engine.go:68–97

NewActorEngine 创建 Actor 化的工作流引擎

(config *EngineConfig, actorConfig *ActorEngineConfig)

// NewActorEngine 创建 Actor 化的工作流引擎
func NewActorEngine(config *EngineConfig, actorConfig *ActorEngineConfig) (*ActorEngine, error) {
	// 创建基础引擎
	engine, err := NewEngine(config)
	if err != nil {
		return nil, err
	}

	if actorConfig == nil {
		actorConfig = DefaultActorEngineConfig()
	}

	// 创建 Actor 系统
	systemConfig := actor.DefaultSystemConfig()
	systemConfig.MailboxSize = 10000
	actorSystem := actor.NewSystemWithConfig(actorConfig.SystemName, systemConfig)

	ae := &ActorEngine{
		Engine:      engine,
		actorSystem: actorSystem,
		agentPIDs:   make(map[string]*actor.PID),
		actorConfig: actorConfig,
	}

	// 创建协调器 Actor
	coordinator := NewCoordinatorActor(ae)
	ae.coordinatorPID = actorSystem.Spawn(coordinator, "coordinator")

	wfLog.Info(context.Background(), "actor engine created", map[string]any{"system_name": actorConfig.SystemName})
	return ae, nil
}

// ExecuteWithActors 使用 Actor 模型执行工作流
func (e *ActorEngine) ExecuteWithActors(ctx context.Context, workflowID string, inputs map[string]any) (*WorkflowResult, error) {