Function TestSystem_ConcurrentMessages

pkg/actor/actor_test.go:205–248

(t *testing.T)

}

func TestSystem_ConcurrentMessages(t *testing.T) {
	// 使用更大的邮箱配置
	config := DefaultSystemConfig()
	config.MailboxSize = 50000
	config.DefaultActorMailboxSize = 20000
	system := NewSystemWithConfig("test", config)
	defer system.Shutdown()

	counter := &CounterActor{}
	props := &Props{
		Name:        "counter",
		MailboxSize: 20000,
	}
	pid := system.SpawnWithProps(counter, props)

	// 并发发送消息
	var wg sync.WaitGroup
	numGoroutines := 100
	messagesPerGoroutine := 100

	for range numGoroutines {
		wg.Add(1)
		go func() {
			defer wg.Done()
			for range messagesPerGoroutine {
				system.Send(pid, &CountMsg{Value: 1})
			}
		}()
	}

	wg.Wait()
	time.Sleep(200 * time.Millisecond)

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

	select {
	case count := <-replyCh:
		assert.Equal(t, numGoroutines*messagesPerGoroutine, count)
	case <-time.After(time.Second):
		t.Fatal("timeout waiting for count")
	}
}

func TestSystem_Stop(t *testing.T) {
	system := NewSystem("test")