Function runSupervisorDemo

examples/actor/main.go:308–351

runSupervisorDemo 监督者策略演示

(ctx context.Context, cmd *cli.Command)

// runSupervisorDemo 监督者策略演示
func runSupervisorDemo(ctx context.Context, cmd *cli.Command) error {
	fmt.Println("\n🛡️ 监督者策略演示（故障恢复）")
	fmt.Println(strings.Repeat("=", 50))

	// 使用自定义配置，静默 panic 日志
	config := actor.DefaultSystemConfig()
	config.PanicHandler = func(a *actor.PID, msg actor.Message, err any) {
		// 静默处理，不打印堆栈
	}
	system := actor.NewSystemWithConfig("supervisor-demo", config)
	defer system.Shutdown()

	// 创建不稳定的 Actor（会失败 2 次）
	unstable := &UnstableActor{name: "Unstable", maxFails: 2}

	// 使用 OneForOne 监督策略（允许 5 次重启）
	props := &actor.Props{
		Name:               "unstable",
		MailboxSize:        100,
		SupervisorStrategy: actor.NewOneForOneStrategy(5, time.Minute, actor.DefaultDecider),
	}
	pid := system.SpawnWithProps(unstable, props)

	fmt.Println("\n📤 发送消息，触发故障和自动恢复...")

	// 发送消息触发故障
	for i := 1; i <= 4; i++ {
		fmt.Printf("\n--- 第 %d 次尝试 ---\n", i)
		resp, err := pid.Request(&PingMsg{Count: i}, 2*time.Second)
		if err != nil {
			fmt.Printf("⏳ 请求超时（Actor 可能正在重启）\n")
			time.Sleep(200 * time.Millisecond)
			continue
		}

		if pong, ok := resp.(*PongMsg); ok {
			fmt.Printf("📥 成功收到 Pong(%d) - Actor 已恢复!\n", pong.Count)
		}
	}

	fmt.Println("\n✅ 监督者策略演示完成!")
	fmt.Println("   Actor 在 2 次故障后自动恢复并正常工作")
	return nil
}

// runPipelineDemo 流水线处理演示
func runPipelineDemo(ctx context.Context, cmd *cli.Command) error {