Golang多路复用计时器库multitick使用指南

multitick是一个用于Golang的多路复用计时器库，它允许你高效地管理多个计时器，并通过单个通道接收所有计时器事件。下面我将详细介绍如何使用这个库。

安装

首先安装multitick库：

go get github.com/yourusername/multitick

基本用法

package main

import (
	"fmt"
	"time"
	
	"github.com/yourusername/multitick"
)

func main() {
	// 创建多路计时器
	mt := multitick.NewMultiTick()

	// 添加计时器
	tick1 := mt.AddTicker(1 * time.Second, "tick1") // 每秒触发
	tick2 := mt.AddTicker(2 * time.Second, "tick2") // 每2秒触发
	tick3 := mt.AddTicker(500 * time.Millisecond, "tick3") // 每500毫秒触发

	// 启动计时器
	mt.Start()

	// 处理计时事件
	go func() {
		for event := range mt.Events() {
			switch event.ID {
			case "tick1":
				fmt.Println("每秒计时器触发:", event.Time)
			case "tick2":
				fmt.Println("每2秒计时器触发:", event.Time)
			case "tick3":
				fmt.Println("每500毫秒计时器触发:", event.Time)
			}
		}
	}()

	// 运行一段时间后停止
	time.Sleep(5 * time.Second)
	
	// 移除单个计时器
	mt.RemoveTicker(tick1)
	
	// 继续运行
	time.Sleep(3 * time.Second)
	
	// 停止所有计时器
	mt.Stop()
}

高级功能

动态添加和移除计时器

func dynamicExample() {
	mt := multitick.NewMultiTick()
	mt.Start()

	// 动态添加计时器
	go func() {
		time.Sleep(2 * time.Second)
		tick4 := mt.AddTicker(300 * time.Millisecond, "dynamic-tick")
		fmt.Println("动态添加了300毫秒计时器")
		
		time.Sleep(2 * time.Second)
		mt.RemoveTicker(tick4)
		fmt.Println("移除了动态添加的计时器")
	}()

	for event := range mt.Events() {
		fmt.Printf("收到事件: %s at %v\n", event.ID, event.Time)
	}
}

重置计时器

func resetExample() {
	mt := multitick.NewMultiTick()
	tick := mt.AddTicker(1 * time.Second, "resettable")
	mt.Start()

	go func() {
		time.Sleep(2500 * time.Millisecond)
		fmt.Println("重置计时器间隔为2秒")
		mt.ResetTicker(tick, 2 * time.Second)
	}()

	for event := range mt.Events() {
		fmt.Println("计时器触发:", event.Time)
	}
}

带缓冲的事件通道

func bufferedExample() {
	// 创建带100缓冲的事件通道
	mt := multitick.NewMultiTickWithBuffer(100)
	
	tick1 := mt.AddTicker(1 * time.Second, "buffered1")
	tick2 := mt.AddTicker(1 * time.Second, "buffered2")
	
	mt.Start()
	
	// 模拟高负载情况
	go func() {
		for i := 0; i < 1000; i++ {
			time.Sleep(10 * time.Millisecond)
			fmt.Println("处理其他任务...")
		}
	}()
	
	for event := range mt.Events() {
		fmt.Println("处理计时事件:", event.ID)
	}
}

性能考虑

1. multitick使用单个goroutine管理所有计时器，减少了goroutine数量
2. 事件通道可以设置缓冲大小以应对突发流量
3. 内部使用最小堆数据结构高效管理计时器触发顺序

错误处理

func errorHandling() {
	mt := multitick.NewMultiTick()
	
	// 尝试添加无效间隔的计时器
	_, err := mt.AddTickerWithError(-1 * time.Second, "invalid")
	if err != nil {
		fmt.Println("添加计时器错误:", err)
	}
	
	// 正常添加
	tick, _ := mt.AddTickerWithError(1 * time.Second, "valid")
	
	// 尝试移除不存在的计时器
	err = mt.RemoveTicker(123) // 假设123是无效ID
	if err != nil {
		fmt.Println("移除计时器错误:", err)
	}
	
	// 正常移除
	mt.RemoveTicker(tick)
}

实际应用场景

1. 网络心跳检测：管理多个连接的心跳计时器
2. 定时任务调度：执行不同间隔的定时任务
3. 游戏开发：处理多个游戏对象的定时更新
4. 监控系统：定期检查不同服务的状态

multitick库通过统一管理多个计时器，简化了代码结构，提高了性能，是处理多计时器场景的理想选择。