Method applyDirective

pkg/actor/system.go:569–604

applyDirective 应用监督指令

(cell *actorCell, directive Directive)

// applyDirective 应用监督指令
func (s *System) applyDirective(cell *actorCell, directive Directive) {
	switch directive {
	case DirectiveResume:
		// 继续运行，不做处理
		actorLog.Info(context.Background(), "actor resumed after failure", map[string]any{"actor_id": cell.pid.ID})

	case DirectiveRestart:
		cell.restarts++
		cell.stateMu.Lock()
		cell.state = actorStateRestarting
		cell.stateMu.Unlock()

		// 发送 Restarting 消息
		ctx := &Context{Self: cell.pid, system: s, ctx: cell.ctx}
		cell.actor.Receive(ctx, &Restarting{})

		// 重新发送 Started 消息
		s.Send(cell.pid, &Started{})

		cell.stateMu.Lock()
		cell.state = actorStateRunning
		cell.stateMu.Unlock()

		actorLog.Info(context.Background(), "actor restarted", map[string]any{"actor_id": cell.pid.ID, "total_restarts": cell.restarts})

	case DirectiveStop:
		s.Stop(cell.pid)

	case DirectiveEscalate:
		if cell.parent != nil {
			// 将失败上报给父 Actor
			s.Send(cell.parent, &Terminated{Who: cell.pid})
		}
		s.Stop(cell.pid)
	}
}

// restartAllSiblings 重启所有兄弟 Actor（用于 AllForOne 策略）
func (s *System) restartAllSiblings(child *PID) {