Function demonstrateStepTrigger

examples/scheduler/main.go:39–65

示例 1: 步骤触发

()

// 示例 1: 步骤触发
func demonstrateStepTrigger() {
	fmt.Println("--- 示例 1: 步骤触发 ---")

	scheduler := core.NewScheduler(nil)
	defer scheduler.Shutdown()

	// 每 3 步执行一次
	taskID, err := scheduler.EverySteps(3, func(ctx context.Context, stepCount int) error {
		fmt.Printf("✓ 步骤任务触发: 第 %d 步\n", stepCount)
		return nil
	})

	if err != nil {
		log.Fatalf("创建步骤任务失败: %v", err)
	}

	fmt.Printf("步骤任务已创建: %s\n", taskID)

	// 模拟 Agent 执行多个步骤
	for i := 1; i <= 10; i++ {
		scheduler.NotifyStep(i)
		time.Sleep(100 * time.Millisecond)
	}

	time.Sleep(200 * time.Millisecond)
	fmt.Println()
}

// 示例 2: 时间间隔触发
func demonstrateIntervalTrigger() {