golang 定时器

outtime.go

package main
import "time"
import "fmt"
func main() {
  // 在这个例子中， 假设我们执行了一个外部调用， 2秒之后将结果写入c1
  c1 := make(chan string, 1)
  go func() {
    time.Sleep(time.Second * 2)
    c1 <- "result 1"
  }()
  // 这里使用select来实现超时， `res := <-c1`等待通道结果，
  // `<- Time.After`则在等待1秒后返回一个值， 因为select首先
  // 执行那些不再阻塞的case， 所以这里会执行超时程序， 如果
  // `res := <-c1`超过1秒没有执行的话
  select {
    case res := <-c1:
    fmt.Println(res)
    case <-time.After(time.Second * 1):
    fmt.Println("timeout 1")
  } /
  / 如果我们将超时时间设为3秒， 这个时候`res := <-c2`将在
  // 超时case之前执行， 从而能够输出写入通道c2的值
  c2 := make(chan string, 1)
  go func() {
    time.Sleep(time.Second * 2)
    c2 <- "result 2"
  }()
  select {
    case res := <-c2:
    fmt.Println(res)
    case <-time.After(time.Second * 3):
    fmt.Println("timeout 2")
  }
}

ticker.go

package main
import "time"
import "fmt"
func main() {
  // Ticker使用和Timer相似的机制， 同样是使用一个通道来发送数据。
  // 这里我们使用range函数来遍历通道数据， 这些数据每隔500毫秒被
  // 发送一次， 这样我们就可以接收到
  ticker := time.NewTicker(time.Millisecond * 500)
  go func() {
    for t := range ticker.C {
    fmt.Println("Tick at", t)
    }
  }()
  // Ticker和Timer一样可以被停止。 一旦Ticker停止后， 通道将不再
  // 接收数据， 这里我们将在1500毫秒之后停止
  time.Sleep(time.Millisecond * 1500)
  ticker.Stop()
  fmt.Println("Ticker stopped")
}