Function TestInMemoryTaskStore_Concurrency

pkg/a2a/store_test.go:107–132

(t *testing.T)

}

func TestInMemoryTaskStore_Concurrency(t *testing.T) {
	store := NewInMemoryTaskStore()
	agentID := "agent-1"

	// 并发保存任务
	const numTasks = 100
	done := make(chan bool, numTasks)

	for i := range numTasks {
		go func(id int) {
			task := NewTask(string(rune('a'+id)), "context-1")
			_ = store.Save(agentID, task)
			done <- true
		}(i)
	}

	// 等待所有任务完成
	for range numTasks {
		<-done
	}

	// 验证任务已保存(数量可能少于numTasks,因为有ID冲突)
	tasks, err := store.List(agentID)
	require.NoError(t, err)
	assert.NotEmpty(t, tasks)
}

func TestTask_StateTransitions(t *testing.T) {
	task := NewTask("task-1", "context-1")