Function concurrentTasksExample

examples/long-running-tools/main.go:135–166

concurrentTasksExample 并发多任务示例

(ctx context.Context)

// concurrentTasksExample 并发多任务示例
func concurrentTasksExample(ctx context.Context) {
	executor := tools.NewLongRunningExecutor()
	tool := NewMockDataProcessingTool(executor)

	// 启动多个任务
	taskIDs := make([]string, 5)
	for i := range 5 {
		taskID, _ := tool.StartAsync(ctx, map[string]any{
			"data_size": 100 * (i + 1),
			"delay_ms":  200,
		})
		taskIDs[i] = taskID
	}

	fmt.Printf("✅ Started %d concurrent tasks\n", len(taskIDs))

	// 等待所有任务完成
	for _, taskID := range taskIDs {
		_, err := tools.WaitForCompletion(executor, taskID, 50*time.Millisecond, 5*time.Second)
		if err != nil {
			log.Printf("Task %s failed: %v", taskID, err)
		}
	}

	// 列出所有任务
	allTasks := executor.ListTasks(nil)
	completedTasks := executor.ListTasks(func(s *tools.TaskStatus) bool {
		return s.State == tools.TaskStateCompleted
	})

	fmt.Printf("✅ All tasks: %d, Completed: %d\n", len(allTasks), len(completedTasks))
}

// cleanupExample 任务清理示例
func cleanupExample(ctx context.Context) {