時(shí)間輪數(shù)組：
[Slot0][Slot1][Slot2]...[Slot511]
  ↑       ↑       ↑         ↑
 指針    100ms后   200ms后    51.1秒后

調(diào)度線程池（單線程）：
    ↓
周期性移動(dòng)指針
    ↓
處理槽位任務(wù)
    ↓
提交到工作線程池

工作線程池（多線程）：
    ↓
并發(fā)執(zhí)行任務(wù)
    ↓
處理業(yè)務(wù)邏輯
    ↓
更新任務(wù)狀態(tài)

@Service
public class TimingWheelService {
    // 任務(wù)管理
    public String scheduleTask(TimerTask task, long delayMs);
    public boolean cancelTask(String taskId);
    public List<TimerTaskWrapper> getActiveTasks();

    // 統(tǒng)計(jì)信息
    public TimingWheelStats getStats();
    public TaskExecutionStats getExecutionStats();

    // 任務(wù)清理
    public int cleanupCompletedTasks();

    // 示例任務(wù)
    public String createSampleTask(String type, long delayMs);
    public List<String> createBatchTasks(int count, long minDelay, long maxDelay);
}

/**
 * 時(shí)間輪配置類
 */
@Configuration
@EnableConfigurationProperties(TimingWheelProperties.class)
public class TimingWheelConfig {

    @Bean
    public TimingWheel timingWheel(TimingWheelProperties properties, MeterRegistry meterRegistry) {
        log.info("Creating timing wheel with properties: {}", properties);
        return new TimingWheel(properties, meterRegistry);
    }

    @Bean
    public MetricsConfig metricsConfig(MeterRegistry meterRegistry) {
        return new MetricsConfig(meterRegistry);
    }

    @Bean
    public WebConfig webConfig() {
        return new WebConfig();
    }
}

/**
 * 時(shí)間輪控制器
 */
@RestController
@RequestMapping("/api/timingwheel")
@CrossOrigin(origins = "*")
public class TimingWheelController {

    @Autowired
    private TimingWheelService timingWheelService;

    /**
     * 獲取時(shí)間輪統(tǒng)計(jì)信息
     */
    @GetMapping("/stats")
    public ResponseEntity<TimingWheel.TimingWheelStats> getStats() {
        TimingWheel.TimingWheelStats stats = timingWheelService.getStats();
        return ResponseEntity.ok(stats);
    }

    /**
     * 創(chuàng)建示例任務(wù)
     */
    @PostMapping("/tasks/sample")
    public ResponseEntity<Map<String, Object>> createSampleTask(@RequestBody Map<String, Object> request) {
        String type = (String) request.getOrDefault("type", "simple");
        long delay = ((Number) request.getOrDefault("delay", 1000)).longValue();

        String taskId = timingWheelService.createSampleTask(type, delay);

        Map<String, Object> response = new HashMap<>();
        response.put("taskId", taskId);
        response.put("type", type);
        response.put("delay", delay);
        response.put("message", "Task created successfully");

        return ResponseEntity.ok(response);
    }

    /**
     * 批量創(chuàng)建任務(wù)
     */
    @PostMapping("/tasks/batch")
    public ResponseEntity<Map<String, Object>> createBatchTasks(@RequestBody Map<String, Object> request) {
        int count = (Integer) request.getOrDefault("count", 10);
        long minDelay = ((Number) request.getOrDefault("minDelay", 1000)).longValue();
        long maxDelay = ((Number) request.getOrDefault("maxDelay", 10000)).longValue();

        List<String> taskIds = timingWheelService.createBatchTasks(count, minDelay, maxDelay);

        Map<String, Object> response = new HashMap<>();
        response.put("taskIds", taskIds);
        response.put("count", taskIds.size());
        response.put("message", "Batch tasks created successfully");

        return ResponseEntity.ok(response);
    }

    /**
     * 壓力測(cè)試
     */
    @PostMapping("/stress-test")
    public ResponseEntity<Map<String, Object>> stressTest(@RequestBody Map<String, Object> request) {
        int taskCount = (Integer) request.getOrDefault("taskCount", 1000);
        long minDelay = ((Number) request.getOrDefault("minDelay", 100)).longValue();
        long maxDelay = ((Number) request.getOrDefault("maxDelay", 5000)).longValue();

        long startTime = System.currentTimeMillis();
        List<String> taskIds = timingWheelService.createBatchTasks(taskCount, minDelay, maxDelay);
        long endTime = System.currentTimeMillis();

        Map<String, Object> response = new HashMap<>();
        response.put("taskCount", taskIds.size());
        response.put("creationTime", endTime - startTime);
        response.put("throughput", taskIds.size() * 1000.0 / (endTime - startTime));
        response.put("message", "Stress test completed successfully");

        return ResponseEntity.ok(response);
    }
}

# application.yml
server:
  port: 8081
  servlet:
    context-path: /

spring:
  application:
    name: springboot-timingwheel

# Timing Wheel Configuration
timingwheel:
  config:
    slot-size: 512
    tick-duration: 100
    worker-threads: 4
    enable-multi-wheel: true
    enable-metrics: true
    task-timeout: 30000

logging:
  level:
    com.example.timingwheel: DEBUG
    org.springframework.web: INFO
  pattern:
    console: "%d{yyyy-MM-dd HH:mm:ss} [%thread] %-5level %logger{36} - %msg%n"