Function demonstrateTaskCancellation

examples/scheduler/main.go:159–185

示例 5: 任务取消

()

// 示例 5: 任务取消
func demonstrateTaskCancellation() {
	fmt.Println("--- 示例 5: 任务取消 ---")

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

	// 创建定时任务
	taskID, _ := scheduler.EveryInterval(300*time.Millisecond, func(ctx context.Context) error {
		fmt.Println("  ⏰ 定时任务执行")
		return nil
	})

	fmt.Printf("任务 %s 已创建,运行 1 秒...\n", taskID)
	time.Sleep(1 * time.Second)

	// 取消任务
	err := scheduler.Cancel(taskID)
	if err != nil {
		log.Printf("取消任务失败: %v", err)
	} else {
		fmt.Println("✓ 任务已取消")
	}

	fmt.Println("再等待 1 秒,验证任务已停止...")
	time.Sleep(1 * time.Second)
	fmt.Println()
}

// 示例 6: 触发回调监控
func demonstrateTriggerMonitoring() {