Function TestActorHighThroughput

examples/actor/actor_test.go:283–326

============================================================================= 高级测试 =============================================================================

(t *testing.T)

// =============================================================================

func TestActorHighThroughput(t *testing.T) {
	if testing.Short() {
		t.Skip("跳过高吞吐量测试（-short 模式）")
	}

	config := actor.DefaultSystemConfig()
	config.MailboxSize = 100000
	config.DefaultActorMailboxSize = 50000
	system := actor.NewSystemWithConfig("throughput", config)
	defer system.Shutdown()

	// 创建计数器 Actor
	var processed int64
	counterFunc := actor.ActorFunc(func(ctx *actor.Context, msg actor.Message) {
		if _, ok := msg.(*IncrementMsg); ok {
			atomic.AddInt64(&processed, 1)
		}
	})

	props := &actor.Props{
		Name:        "counter",
		MailboxSize: 50000,
	}
	pid := system.SpawnWithProps(counterFunc, props)

	// 发送大量消息
	numMessages := 100000
	start := time.Now()

	for range numMessages {
		pid.Tell(&IncrementMsg{Value: 1})
	}

	// 等待处理完成
	for atomic.LoadInt64(&processed) < int64(numMessages) {
		time.Sleep(10 * time.Millisecond)
	}

	elapsed := time.Since(start)
	throughput := float64(numMessages) / elapsed.Seconds()

	t.Logf("处理 %d 条消息耗时 %v，吞吐量: %.0f msg/s", numMessages, elapsed, throughput)
	assert.GreaterOrEqual(t, throughput, 10000.0, "吞吐量应至少 10K msg/s")
}

// =============================================================================
// 测试入口