Function demonstrateMultipleTasks

examples/scheduler/main.go:119–156

示例 4: 多任务调度

()

// 示例 4: 多任务调度
func demonstrateMultipleTasks() {
	fmt.Println("--- 示例 4: 多任务调度 ---")

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

	// 任务 1: 每 2 步
	_, _ = scheduler.EverySteps(2, func(ctx context.Context, stepCount int) error {
		fmt.Printf("  [任务A] 每2步 - 第 %d 步\n", stepCount)
		return nil
	})

	// 任务 2: 每 5 步
	_, _ = scheduler.EverySteps(5, func(ctx context.Context, stepCount int) error {
		fmt.Printf("  [任务B] 每5步 - 第 %d 步\n", stepCount)
		return nil
	})

	// 任务 3: 每 300ms
	_, _ = scheduler.EveryInterval(300*time.Millisecond, func(ctx context.Context) error {
		fmt.Printf("  [任务C] 定时触发\n")
		return nil
	})

	fmt.Printf("已创建 3 个任务\n")
	fmt.Printf("步骤任务: %d, 定时任务: %d\n",
		scheduler.GetStepTaskCount(),
		scheduler.GetIntervalTaskCount())

	// 模拟步骤
	for i := 1; i <= 10; i++ {
		scheduler.NotifyStep(i)
		time.Sleep(150 * time.Millisecond)
	}

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

// 示例 5: 任务取消
func demonstrateTaskCancellation() {