Method spawnWithProps

pkg/actor/system.go:197–257

spawnWithProps 使用属性创建

(actor Actor, props *Props, parent *PID)

// spawnWithProps 使用属性创建
func (s *System) spawnWithProps(actor Actor, props *Props, parent *PID) *PID {
	s.actorsMu.Lock()
	defer s.actorsMu.Unlock()

	// 检查名称是否已存在
	if _, exists := s.actors[props.Name]; exists {
		actorLog.Debug(context.Background(), "actor already exists, returning existing PID", map[string]any{"name": props.Name})
		return s.actors[props.Name].pid
	}

	// 创建 PID
	pid := &PID{
		ID:     props.Name,
		system: s,
	}

	// 创建上下文
	ctx, cancel := context.WithCancel(s.ctx)

	// 确定邮箱大小
	mailboxSize := props.MailboxSize
	if mailboxSize <= 0 {
		mailboxSize = s.config.DefaultActorMailboxSize
	}

	// 创建 Actor 单元
	cell := &actorCell{
		pid:        pid,
		actor:      actor,
		mailbox:    make(chan envelope, mailboxSize),
		parent:     parent,
		children:   make(map[string]*PID),
		watchers:   make(map[string]*PID),
		watching:   make(map[string]*PID),
		state:      actorStateIdle,
		supervisor: props.SupervisorStrategy,
		ctx:        ctx,
		cancel:     cancel,
	}

	// 注册
	s.actors[props.Name] = cell
	atomic.AddInt64(&s.stats.TotalActors, 1)

	// 如果有父 Actor，注册为子 Actor
	if parent != nil {
		if parentCell, ok := s.actors[parent.ID]; ok {
			parentCell.children[props.Name] = pid
		}
	}

	// 启动 Actor 消息循环
	s.wg.Add(1)
	go s.actorLoop(cell)

	// 发送 Started 消息
	s.SendWithSender(pid, &Started{}, nil)