Method TestSupervisorRestart

examples/actor/actor_test.go:106–141

()

}

func (s *ActorSuite) TestSupervisorRestart() {
	// 使用静默 panic 处理器
	config := actor.DefaultSystemConfig()
	config.PanicHandler = func(a *actor.PID, msg actor.Message, err any) {}
	s.system.Shutdown()
	s.system = actor.NewSystemWithConfig("test", config)

	// 创建不稳定的 Actor（会失败 2 次）
	unstable := &UnstableActor{name: "unstable", maxFails: 2}
	props := &actor.Props{
		Name:               "unstable",
		MailboxSize:        100,
		SupervisorStrategy: actor.NewOneForOneStrategy(5, time.Minute, actor.DefaultDecider),
	}
	pid := s.system.SpawnWithProps(unstable, props)

	// 第一次请求会触发 panic
	_, err := pid.Request(&PingMsg{Count: 1}, 500*time.Millisecond)
	s.Error(err, "第一次请求应超时（Actor panic）")

	time.Sleep(100 * time.Millisecond)

	// 第二次请求也会触发 panic
	_, err = pid.Request(&PingMsg{Count: 2}, 500*time.Millisecond)
	s.Error(err, "第二次请求应超时（Actor panic）")

	time.Sleep(100 * time.Millisecond)

	// 第三次请求应该成功（Actor 已恢复）
	resp, err := pid.Request(&PingMsg{Count: 3}, time.Second)
	s.Require().NoError(err, "第三次请求应成功")

	pong, ok := resp.(*PongMsg)
	s.Require().True(ok, "响应应为 PongMsg")
	s.Equal(3, pong.Count, "计数应匹配")
}

func (s *ActorSuite) TestPipeline() {
	// 创建 3 阶段流水线