select、定時器

發布時間：2020-07-02 13:23:42 來源：網絡閱讀：316 作者：梁十八欄目：編程語言

應用場景舉例：
一個任務管道滿了，再往里面塞就塞不進去了，瀏覽器刷不出來了。用戶即便關了瀏覽器可能依然在阻塞......

package main

import "fmt"
import "time"

func main() {
   var ch chan int
   ch = make(chan int, 10)
   ch3 := make(chan int, 10)
   go func() {
      var i int
      for {
         ch <- i
         time.Sleep(time.Second)
         ch3 <- i * i
         time.Sleep(time.Second)
         i++
      }
   }()
   for {
      select { //這個case如果不能從ch中獲取數據，則會立即走下一個
      case v := <-ch:
         fmt.Println(v) //這個case如果不能從ch3中獲取數據，則會立即走下一個
      case v := <-ch3:
         fmt.Println(v) //然而這樣寫可能有內存泄漏！
      case <-time.After(time.Second):
         fmt.Println("get data timeout")
         time.Sleep(time.Second)
      default:
         fmt.Println("===================")
         time.Sleep(time.Second)
      }
   }
}

上面的寫法可能會有內存泄漏！

package main

import (
   "fmt"
   "runtime"
   "time"
)

func main() {
   num := runtime.NumCPU()
   runtime.GOMAXPROCS(num - 1)
   for i := 0; i < 16; i++ {
      go func() {
         for { 
            //每秒執行一次
            t := time.NewTicker(time.Second)
            select {
            case <-t.C:
               fmt.Println("timeout")
            } //一定要關閉
            t.Stop()
         }
      }()
   }

   time.Sleep(time.Second * 100)
}

go官方文檔的建議：
select、定時器