4

我正在开发控制台音乐播放器Go。每当用户选择并播放专辑时，我都会启动一个 goroutine来循环播放列表。

playlist := make([]*Media, 0)
for _, path := range album.Paths {
    media, err := NewMediaFromPath(path)
    // return err

    playlist = append(playlist, media)
}

for idx := range playlist {
    player.SetMedia(playlist[idx])
    err = player.Play()
    // check err

    status, err := player.MediaState()
    // check err

    for status != MediaEnded && status != MediaStopped {
        // update UI and check player status
        // loop until the song finishes
        status, err = player.MediaState()
    }
}

当用户选择新专辑时，我需要一种取消此 goroutine的方法。我习惯这样做（但我不相信这是最好的解决方案）。context.Context

我创建ctx

    ctx, cancel := context.WithCancel(context.Background())

所以在 UI 事件处理程序中，play() func将cancel()goroutine。

一旦我检查更新 UIfor循环，这就会起作用：

        select {
        case <-ctx.Done():
            return err
        default:
            time.Sleep(50 * time.Millisecond)
        }

然后通道ctx.Done()关闭，下一张播放的专辑将始终返回而不是循环播放。

有没有办法取消a context.Context？

如果没有，有没有更好的方法来取消这个 goroutine（以及以下 goroutines）？

或者，我尝试使用等待组，

    go func() {
        wg.Wait()
        wg.Add(1)
        err = playAlbum(
            done,
            player,
            *albums[s],
            list,
            status,
        )
        wg.Done()
        // handle err
     }()

但后来我感到sync: WaitGroup is reused before previous Wait has returned恐慌

4

1 回答 1

2

使用通道取消 goroutine 怎么样？

select {
case <-chClose:
    return
default:
}

您的 cancel() 调用可以简单地关闭通道：

close(chClose)

但是你不能再次关闭它！所以你需要确保你的新专辑有一个新的 chClose。根据您的代码结构，这可能是更清洁的解决方案。

或者，您可以在 chClose 上发送一个值来启动 go 例程的停止：

chClose <- 1

您可以根据需要随时执行此操作。

请注意，如果没有 goroutine 监听，这将阻塞（或者如果你有一个缓冲区，你最终会关闭甚至还没有 startet 的例程。--> 你需要一个干净的架构！！）

于 2017-07-03T10:27:48.440 回答