golang.org/x/time/rate 提對(duì)速度進(jìn)行限制的算法

l := rate.NewLimiter(1, 3) // 一個(gè)參數(shù)為每秒發(fā)生多少次事件，第二個(gè)參數(shù)是最大可運(yùn)行多少個(gè)事件(burst)

Limter提供三中主要的函數(shù) Allow, Reserve, Wait. 大部分時(shí)候使用Wait

Wait/WaitN 當(dāng)沒(méi)有可用事件時(shí)，將阻塞等待

c, _ := context.WithCancel(context.TODO())
for {
 l.Wait(c)
 fmt.Println(time.Now().Format("04:05.000"))
}

輸出

07:35.055
07:35.055
07:35.055
07:36.060
07:37.059
07:38.059

緩存3次后，每秒執(zhí)行一次

Allow/AllowN 當(dāng)沒(méi)有可用事件時(shí)，返回false
for {
 if (l.AllowN(time.Now(), 1)) {
  fmt.Println(time.Now().Format("04:05.000"))
 } else {
  time.Sleep(1 * time.Second / 10)
  fmt.Println(time.Now().Format("Second 04:05.000"))
 }

}

Reserve/ReserveN 當(dāng)沒(méi)有可用事件時(shí)，返回 Reservation，和要等待多久才能獲得足夠的事件

for {
  r := l.ReserveN(time.Now(), 1)
  s := r.Delay()
  time.Sleep(s)
   fmt.Println(s, time.Now().Format("04:05.000"))

 }

補(bǔ)充：關(guān)于golang.org/x包問(wèn)題

由于谷歌被墻，跟谷歌相關(guān)的模塊無(wú)法通過(guò)go get來(lái)下載

解決方法：

git clone https://github.com/golang/net.git $GOPATH/src/github.com/golang/net

git clone https://github.com/golang/sys.git $GOPATH/src/github.com/golang/sys

git clone https://github.com/golang/tools.git $GOPATH/src/github.com/golang/tools

ln -s $GOPATH/src/github.com/golang $GOPATH/src/golang.org/x

如果是Windows下，最后一條可以替換為mklink命令，或者直接拷貝文件夾修改一下名稱即可。

go的官方包都在這個(gè)目錄下：

https://github.com/golang

以上為個(gè)人經(jīng)驗(yàn)，希望能給大家一個(gè)參考，也希望大家多多支持腳本之家。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教。