停止时间。新计时器初始化在 for 循环内

Question

我有一个类似于以下程序的程序：package mainimport (    "fmt"    "time")func main() {    ch := make(chan string)    go endProgram(ch)    printFunc(ch)}func printFunc(ch chan string) {    for {        timeout := time.NewTimer(getTimeoutDuration())        defer timeout.Stop()        select {        case s := <-ch:            fmt.Println(s)            return        case <-timeout.C:            fmt.Println("Current value")        }    }}func endProgram(ch chan string) {    time.Sleep(time.Second * 8)    ch <- "Exit function"}func getTimeoutDuration() time.Duration {    return time.Second * 3}在这种情况下，停止计时器的最佳方法是什么？timeout我知道上面不是推荐的方法，因为使用for loop内部的延迟是一种不好的做法。另一种方法是在for循环中使用，而不是因为我们不必停止。但如果函数在计时器触发（源）之前退出，则会导致资源泄漏。time.Aftertime.NewTimertime.Aftertime.After

Answer 1

如果使用上下文而不是计时器，则仅在退出函数大小写条件时调用取消。

package main

import (

    "context"

    "fmt"

    "time"

)

func main() {

    ch := make(chan string)

    go endProgram(ch)

    printFunc(ch)

}

func printFunc(ch chan string) {

    for {

        ctx, cancel := context.WithTimeout(context.Background(), getTimeoutDuration())

        select {

        case s := <-ch:

            cancel()

            fmt.Println(s)

            return

        case <-ctx.Done():

            fmt.Println("Current value")

        }

    }

}

func endProgram(ch chan string) {

    time.Sleep(time.Second * 8)

    ch <- "Exit function"

}

func getTimeoutDuration() time.Duration {

    return time.Second * 3

}