股票代码告诉goroutine它是通过它的ticker.C停止的吗？

Question

package main 
import "fmt" 
import "time" 

func main() { 
    ticker := time.NewTicker(time.Millisecond * 500) 
    go func() { 
     for t := range ticker.C { 
      fmt.Println("Tick at", t) 
     } 
     fmt.Println("ticker stopped") 
    }() 
    time.Sleep(time.Second * 5) 
    ticker.Stop() 
    time.Sleep(time.Second * 5) 
} 

我以为当我打电话给ticker.Stop（）时，ticker.C应该告诉goroutine它已经结束，所以for循环应该结束，但它看起来不像那样，字符串“ticker stopped”从不打印。

Answer 1

正如JimB指出的那样，time.Ticker指定Stop（）不会关闭频道，to prevent a read from the channel succeeding incorrectly.您最好的选择可能是退出频道。

package main 

import "fmt" 
import "time" 

func main() { 
    ticker := time.NewTicker(time.Millisecond * 500) 
    quit := make(chan struct{}) 
    go func() { 
     for { 
      select { 
      case t := <-ticker.C: 
       fmt.Println("Tick at", t) 
      case <-quit: 
       fmt.Println("ticker stopped") 
       return 
      } 
     } 
    }() 
    time.Sleep(time.Second * 5) 
    ticker.Stop() 
    close(quit) 
    time.Sleep(time.Second * 5) 
} 

https://play.golang.org/p/xTKNkMtdIf