Function TestSystem_SupervisorRestart

pkg/actor/actor_test.go:172–203

(t *testing.T)

}

func TestSystem_SupervisorRestart(t *testing.T) {
	config := DefaultSystemConfig()
	config.PanicHandler = func(actor *PID, msg Message, err any) {
		// 静默处理 panic
	}
	system := NewSystemWithConfig("test", config)
	defer system.Shutdown()

	// 创建会 panic 的 Actor，使用监督策略
	panicActor := &PanicActor{}
	props := &Props{
		Name:               "panic-actor",
		MailboxSize:        10,
		SupervisorStrategy: NewOneForOneStrategy(5, time.Minute, DefaultDecider),
	}
	pid := system.SpawnWithProps(panicActor, props)

	// 发送消息，触发 panic
	system.Send(pid, &PingMsg{Count: 1})
	time.Sleep(50 * time.Millisecond)

	system.Send(pid, &PingMsg{Count: 2})
	time.Sleep(50 * time.Millisecond)

	// 第三次应该成功
	system.Send(pid, &PingMsg{Count: 3})
	time.Sleep(50 * time.Millisecond)

	// Actor 应该仍然存在（被重启）
	_, exists := system.GetActor("panic-actor")
	assert.True(t, exists)
}

func TestSystem_ConcurrentMessages(t *testing.T) {
	// 使用更大的邮箱配置