Function cleanupExample

examples/long-running-tools/main.go:169–191

cleanupExample 任务清理示例

(ctx context.Context)

// cleanupExample 任务清理示例
func cleanupExample(ctx context.Context) {
	executor := tools.NewLongRunningExecutor()
	tool := NewMockDataProcessingTool(executor)

	// 创建一些任务
	for range 3 {
		taskID, _ := tool.StartAsync(ctx, map[string]any{
			"data_size": 100,
			"delay_ms":  100,
		})
		_, _ = tools.WaitForCompletion(executor, taskID, 50*time.Millisecond, 2*time.Second)
	}

	fmt.Println("✅ Created 3 completed tasks")

	// 清理 1 秒前的任务
	deleted := executor.Cleanup(time.Now().Add(-1 * time.Second))
	fmt.Printf("✅ Cleaned up %d old tasks\n", deleted)

	// 验证
	remaining := executor.ListTasks(nil)
	fmt.Printf("✅ Remaining tasks: %d\n", len(remaining))
}

// ============================================================
// 模拟工具实现