Method handleFailure

pkg/actor/system.go:538–566

handleFailure 处理 Actor 失败

(cell *actorCell, msg Message, err any)

// handleFailure 处理 Actor 失败
func (s *System) handleFailure(cell *actorCell, msg Message, err any) {
	supervisor := cell.supervisor
	if supervisor == nil && cell.parent != nil {
		// 使用父 Actor 的监督策略
		s.actorsMu.RLock()
		if parentCell, ok := s.actors[cell.parent.ID]; ok {
			supervisor = parentCell.supervisor
		}
		s.actorsMu.RUnlock()
	}

	if supervisor == nil {
		supervisor = DefaultSupervisorStrategy()
	}

	result := supervisor.HandleFailure(s, cell.pid, msg, err)

	// 处理返回结果
	switch r := result.(type) {
	case DirectiveWithDelay:
		// 延迟重启
		time.AfterFunc(r.Delay, func() {
			s.applyDirective(cell, r.Directive)
		})
	case Directive:
		// 立即执行
		s.applyDirective(cell, r)
	}
}

// applyDirective 应用监督指令
func (s *System) applyDirective(cell *actorCell, directive Directive) {