Method TestCounterConcurrency

examples/actor/actor_test.go:59–104

()

}

func (s *ActorSuite) TestCounterConcurrency() {
	// 使用更大的邮箱配置
	s.system.Shutdown()
	config := actor.DefaultSystemConfig()
	config.MailboxSize = 20000
	config.DefaultActorMailboxSize = 5000
	s.system = actor.NewSystemWithConfig("test", config)

	// 创建计数器 Actor（使用更大的邮箱）
	counter := &CounterActor{name: "counter", count: 0}
	props := &actor.Props{
		Name:        "counter",
		MailboxSize: 5000,
	}
	pid := s.system.SpawnWithProps(counter, props)

	// 并发发送增量消息
	var wg sync.WaitGroup
	numGoroutines := 10
	incrementsPerGoroutine := 100

	for range numGoroutines {
		wg.Add(1)
		go func() {
			defer wg.Done()
			for range incrementsPerGoroutine {
				pid.Tell(&IncrementMsg{Value: 1})
			}
		}()
	}

	wg.Wait()
	time.Sleep(200 * time.Millisecond) // 等待消息处理完成

	// 获取最终计数
	replyCh := make(chan int, 1)
	pid.Tell(&GetCountMsg{ReplyTo: replyCh})

	select {
	case count := <-replyCh:
		expected := numGoroutines * incrementsPerGoroutine
		s.Equal(expected, count, "并发计数应正确")
	case <-time.After(time.Second):
		s.T().Fatal("获取计数超时")
	}
}

func (s *ActorSuite) TestSupervisorRestart() {
	// 使用静默 panic 处理器