Function demonstrateTriggerMonitoring

examples/scheduler/main.go:188–228

示例 6: 触发回调监控

()

// 示例 6: 触发回调监控
func demonstrateTriggerMonitoring() {
	fmt.Println("--- 示例 6: 触发回调监控 ---")

	var triggerCount int

	scheduler := core.NewScheduler(&core.SchedulerOptions{
		OnTrigger: func(taskID string, spec string, kind core.TriggerKind) {
			triggerCount++
			fmt.Printf("  [监控] 任务触发 - ID: %s, 类型: %s, 规格: %s\n",
				taskID[:8], kind, spec)
		},
	})
	defer scheduler.Shutdown()

	// 创建步骤任务
	_, err := scheduler.EverySteps(2, func(ctx context.Context, stepCount int) error {
		return nil
	})
	if err != nil {
		log.Fatalf("创建步骤任务失败: %v", err)
	}

	// 创建定时任务
	_, err = scheduler.EveryInterval(200*time.Millisecond, func(ctx context.Context) error {
		return nil
	})
	if err != nil {
		log.Fatalf("创建定时任务失败: %v", err)
	}

	// 模拟执行
	for i := 1; i <= 6; i++ {
		scheduler.NotifyStep(i)
		time.Sleep(150 * time.Millisecond)
	}

	time.Sleep(300 * time.Millisecond)

	fmt.Printf("\n总触发次数: %d\n", triggerCount)
	fmt.Println()
}