Function TestPool_Shutdown

pkg/core/pool_test.go:354–382

TestPool_Shutdown 测试关闭池

(t *testing.T)

// TestPool_Shutdown 测试关闭池
func TestPool_Shutdown(t *testing.T) {
	deps := createTestDeps(t)
	pool := NewPool(&PoolOptions{
		Dependencies: deps,
		MaxAgents:    10,
	})

	ctx := context.Background()

	// 创建多个 Agent
	for i := range 5 {
		config := createTestConfig("test-agent-" + string(rune('1'+i)))
		_, err := pool.Create(ctx, config)
		if err != nil {
			t.Fatalf("Failed to create agent: %v", err)
		}
	}

	// 关闭池
	err := pool.Shutdown()
	if err != nil {
		t.Fatalf("Failed to shutdown pool: %v", err)
	}

	// 验证池已清空
	if pool.Size() != 0 {
		t.Errorf("Pool not empty after shutdown, size: %d", pool.Size())
	}
}

// TestPool_ForEach 测试遍历 Agent
func TestPool_ForEach(t *testing.T) {