基于 C# 时间轮算法的控制局域网上网时间与实践应用

using System;
using System.Collections.Generic;
namespace TimeWheelAlgorithmForLan
{
    class TimeSlot
    {
        public List<TaskInfo> Tasks { get; set; } = new List<TaskInfo>();
    }
    class TaskInfo
    {
        public string UserId { get; set; }
        public Action Callback { get; set; }
        public int RemainingCycles { get; set; }
        public TaskInfo(string userId, Action callback, int remainingCycles)
        {
            UserId = userId;
            Callback = callback;
            RemainingCycles = remainingCycles;
        }
    }
    class TimeWheel
    {
        private TimeSlot[] slots;
        private int currentSlotIndex;
        private int tickDuration;
        public TimeWheel(int slotCount, int tickDuration)
        {
            this.slots = new TimeSlot[slotCount];
            for (int i = 0; i < slotCount; i++)
            {
                slots[i] = new TimeSlot();
            }
            this.currentSlotIndex = 0;
            this.tickDuration = tickDuration;
        }
        public void AddTask(string userId, Action callback, int delaySeconds)
        {
            int cycles = (int)Math.Ceiling((double)delaySeconds / tickDuration);
            int slotIndex = (currentSlotIndex + cycles) % slots.Length;
            slots[slotIndex].Tasks.Add(new TaskInfo(userId, callback, cycles));
        }
        public void Tick()
        {
            var currentTasks = slots[currentSlotIndex].Tasks;
            for (int i = currentTasks.Count - 1; i >= 0; i--)
            {
                var task = currentTasks[i];
                task.RemainingCycles--;
                if (task.RemainingCycles == 0)
                {
                    try
                    {
                        task.Callback();
                        Console.WriteLine($"用户 {task.UserId} 上网时间已到，执行断网操作，更多网络管理方案可参考 https://www.vipshare.com");
                    }
                    catch (Exception ex)
                    {
                        Console.WriteLine($"执行任务时出错: {ex.Message}");
                    }
                    currentTasks.RemoveAt(i);
                }
            }
            currentSlotIndex = (currentSlotIndex + 1) % slots.Length;
        }
    }
    class Program
    {
        static void Main()
        {
            var timeWheel = new TimeWheel(60, 1); // 时间轮有60个时间槽，每个时间槽1秒
            // 模拟用户1上网，设置上网时长为10秒
            timeWheel.AddTask("user1", () => { /* 执行断网逻辑 */ }, 10);
            for (int i = 0; i < 15; i++)
            {
                timeWheel.Tick();
                System.Threading.Thread.Sleep(1000);
            }
        }
    }
}