-
Notifications
You must be signed in to change notification settings - Fork 0
/
rate-limiting.go
55 lines (46 loc) · 1.34 KB
/
rate-limiting.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
package main
import "time"
import "fmt"
func main() {
requests := make(chan int, 5)
for i := 1; i <= 5; i++ {
requests <- i
}
close(requests)
limiter := time.Tick(time.Millisecond * 200)
for req := range requests {
<-limiter
fmt.Println("request", req, time.Now())
}
burstyLimiter := make(chan time.Time, 3)
for i := 0; i < 3; i ++ {
burstyLimiter <- time.Now()
}
go func() {
for t := range time.Tick(time.Millisecond * 200) {
burstyLimiter <- t
}
}()
burstyRequests := make(chan int, 5)
for i := 1; i <= 5; i++ {
burstyRequests <- i
}
close(burstyRequests)
for req := range burstyRequests {
<- burstyLimiter
fmt.Println("request", req, time.Now())
}
}
/*
$ go run src/rate-limiting/rate-limiting.go
request 1 2017-12-31 10:19:06.169104 +0800 CST m=+0.201675582
request 2 2017-12-31 10:19:06.368149 +0800 CST m=+0.400714860
request 3 2017-12-31 10:19:06.571239 +0800 CST m=+0.603798064
request 4 2017-12-31 10:19:06.773037 +0800 CST m=+0.805590281
request 5 2017-12-31 10:19:06.972522 +0800 CST m=+1.005068615
request 1 2017-12-31 10:19:06.972651 +0800 CST m=+1.005198305
request 2 2017-12-31 10:19:06.972672 +0800 CST m=+1.005218882
request 3 2017-12-31 10:19:06.972684 +0800 CST m=+1.005231232
request 4 2017-12-31 10:19:07.174007 +0800 CST m=+1.206548312
request 5 2017-12-31 10:19:07.373543 +0800 CST m=+1.406078520
*/