Go语言如何编写一个节流（Throttle）函数？高频事件控制【方法】-Golang-PHP中文网

节流函数的核心逻辑是“固定时间窗口内只执行一次”，通过 time.timer 或 time.afterfunc 管理延迟执行，并用互斥锁或原子操作防止重复调度，每次调用需取消旧定时器并新建。

go语言如何编写一个节流（throttle）函数？高频事件控制【方法】

节流函数的核心逻辑是什么？

节流不是“限制次数”，而是“固定时间窗口内只执行一次”。比如鼠标拖拽、滚动事件，你希望每 100ms 最多响应一次，而不是等事件停了才执行——这和防抖 debounce 本质不同。

Go 没有原生 DOM 事件，但节流在服务端同样有用：限流 HTTP 请求处理、控制日志采样频率、避免高频定时任务堆积。关键在于用 time.Timer 或 time.AfterFunc 管理延迟执行，并用原子状态或互斥锁防止重复调度。

用 `time.AfterFunc` 实现简易节流器

适合单次触发、不关心是否立即执行的场景（比如日志上报）。核心是每次调用都取消旧定时器、新建一个：

Go语言（Golang）1.26.0

Go语言（Golang）1.26.0版本官方下载，版本号 1.26.0，适合旧项目维护、兼容性测试和指定版本开发环境搭建。

下载

type Throttler struct {
	mu     sync.Mutex
	timer  *time.Timer
	fn     func()
}

func NewThrottler(fn func(), interval time.Duration) *Throttler {
	return &Throttler{
		fn: fn,
	}
}

func (t *Throttler) Throttle() {
	t.mu.Lock()
	defer t.mu.Unlock()

	if t.timer != nil {
		t.timer.Stop()
	}
	t.timer = time.AfterFunc(interval, t.fn)
}

t.timer.Stop() 必须调用，否则旧定时器仍会触发，导致多次执行
注意 t.fn 是无参函数；若需传参，建议闭包捕获，或改用带参数的函数签名
该实现不保证首次调用立即执行——如果需要“立即 + 节流”，得额外加标记位和首次执行逻辑

支持立即执行的节流器（leading edge）

前端常见需求：滚动开始时立刻执行一次，之后每 interval 执行一次。Go 中可通过 atomic.Bool + time.AfterFunc 组合实现：

type LeadingThrottler struct {
	mu       sync.Mutex
	timer    *time.Timer
	fn       func()
	interval time.Duration
	running  atomic.Bool
}

func (t *LeadingThrottler) Throttle() {
	if !t.running.Swap(true) {
		t.fn() // 立即执行
		t.startTimer()
	}
}

func (t *LeadingThrottler) startTimer() {
	t.mu.Lock()
	defer t.mu.Unlock()
	if t.timer != nil {
		t.timer.Stop()
	}
	t.timer = time.AfterFunc(t.interval, func() {
		t.running.Store(false)
	})
}