Method Receive

pkg/actor/supervisor.go:356–381

Receive 处理消息

(ctx *Context, msg Message)

// Receive 处理消息
func (s *SupervisorActor) Receive(ctx *Context, msg Message) {
	switch m := msg.(type) {
	case *Started:
		// 启动所有子 Actor
		for _, spec := range s.config.Children {
			child := spec.Factory()
			props := spec.Props
			if props == nil {
				props = DefaultProps(spec.Name)
			}
			props.SupervisorStrategy = s.config.Strategy
			pid := ctx.SpawnWithProps(child, props)
			s.children[spec.Name] = pid
		}

	case *Terminated:
		// 子 Actor 终止，根据策略处理
		delete(s.children, m.Who.ID)

	case *Stopping:
		// 停止所有子 Actor
		for _, pid := range s.children {
			ctx.Stop(pid)
		}
	}
}

// GetChild 获取子 Actor
func (s *SupervisorActor) GetChild(name string) *PID {