Go beep 怎样给音频流添加暂停控制

我在给 Go 播放器加“暂停/继续”按钮时，最省事的做法不是改写底层音频生成器，而是用 beep.Ctrl 包一层 beep.Streamer。把 Paused 设为 true 时，Ctrl 继续向扬声器提供流，但输出的是静音；恢复时改回 false。如果播放中的 Ctrl 要被修改，还要把变更放在 speaker.Lock 和 speaker.Unlock 之间。

官方地址：https://pkg.go.dev/github.com/gopxl/beep

下面只讨论单个音频流的暂停控制，不把“暂停静音”“停止当前流”和“暂停整个扬声器”混成一个动作。

beep.Ctrl 为什么能暂停 Streamer

beep.Ctrl 的职责很小：它保存一个被包装的 Streamer 和一个 Paused 布尔字段。正常状态下，Ctrl 把底层流的数据继续交给 Stream；暂停状态下，Ctrl 让这一段输出变成静音。这样做的好处是底层解码位置仍由原来的 Streamer 管理，恢复播放时不会因为重新创建对象而从头开始。

从使用关系上看，应该让 speaker.Play 接收 Ctrl，而不是直接接收原始 Streamer：

package main

import (
    "github.com/gopxl/beep"
    "github.com/gopxl/beep/speaker"
)

func start(stream beep.Streamer, rate beep.SampleRate) *beep.Ctrl {
    // Ctrl 只负责增加暂停状态，不改变底层 Streamer 的类型。
    ctrl := &beep.Ctrl{Streamer: stream}

    // 初始化扬声器后始终播放 Ctrl，后续按钮只修改 ctrl.Paused。
    if err := speaker.Init(rate, rate.N(100000000)); err != nil {
        panic(err)
    }
    speaker.Play(ctrl)
    return ctrl
}

示例中的缓冲区是约 100 毫秒，换算成纳秒后传给 SampleRate.N。实际项目应按响应速度和播放稳定性调整这个值；这里的重点是把控制对象交给 speaker，而不是声称某个固定缓冲区适合所有设备。

播放中修改 Paused 要锁住 speaker

播放开始后，speaker 会持续从正在播放的 Streamer 拉取样本。如果此时另一个 goroutine 直接改 ctrl.Paused 或替换 ctrl.Streamer，就可能和读取过程同时发生。官方 speaker 文档给出的边界是：修改正在播放的 Streamer 前先锁住 speaker，改完立即解锁。

func setPaused(ctrl *beep.Ctrl, paused bool) {
    // 锁定期间 speaker 不会继续拉取正在播放的 Streamer。
    speaker.Lock()
    ctrl.Paused = paused
    // 只在修改控制字段的最短区间内持锁，避免造成播放卡顿。
    speaker.Unlock()
}

按钮、快捷键或定时器都可以调用这个函数。暂停和恢复都只改一个状态字段，因此锁的持有时间应尽量短；不要把文件读取、网络请求或复杂业务逻辑放进锁内。

暂停静音和彻底停止不是一回事

Paused=true 代表“继续保留这个流，但当前输出静音”。它适合用户点击暂停后稍后继续的场景。官方文档还说明，如果把 Ctrl.Streamer 设为 nil，Ctrl 会被视为 drained，也就是不再继续消费原来的流。

func stop(ctrl *beep.Ctrl) {
    speaker.Lock()
    // nil 表示不再保留底层流；这不是可恢复的暂停。
    ctrl.Streamer = nil
    speaker.Unlock()
}

如果业务还要支持“停止后重新播放”，建议把原始流的创建与 Ctrl 的控制分开：停止时释放旧的解码流，下一次播放重新打开资源并创建新的 Ctrl。不要把已经置为 nil 的 Ctrl 当成暂停对象继续复用。

资源生命周期要跟着底层流走

Ctrl 本身只是包装层，不会替你关闭文件、解码器或其他实现了 beep.StreamCloser 的资源。创建可关闭的音频流后，要让拥有资源的一方负责关闭；如果播放是异步的，不能在调用 speaker.Play 后立刻退出主函数或提前关闭底层流。

func playUntilDone(stream beep.StreamSeekCloser, rate beep.SampleRate) {
    defer stream.Close()

    ctrl := &beep.Ctrl{Streamer: stream}
    if err := speaker.Init(rate, rate.N(100000000)); err != nil {
        // 初始化失败时仍由当前函数关闭已经拿到的流。
        panic(err)
    }

    // 有限流用 PlayAndWait，避免主函数先退出导致播放被截断。
    speaker.PlayAndWait(ctrl)
}

结论与相关问题

Go beep 给音频流添加暂停控制，可以按“原始 Streamer → beep.Ctrl → speaker.Play”组织。暂停只切换 Paused，继续播放再切回 false；播放中修改状态要短暂锁住 speaker；真正停止则应让 Streamer 脱离 Ctrl，并把底层资源的关闭责任收好。

• 暂停后会不会丢失当前播放位置？不会，Ctrl 仍然包着原来的 Streamer；它只是暂时输出静音。
• 可以用 speaker.Suspend 暂停单个音频吗？不适合。Suspend 面向整个扬声器，单个流应使用 beep.Ctrl。
• 为什么修改 Paused 需要 Lock？因为 speaker 可能正在从播放中的 Streamer 拉取数据，锁用于避免并发修改。