1. goroutine
1. 重点
1.要搞清楚goroutine什么时候退出
2. 控制goroutine退出
3. 把并发给调用者
2. 代码示例
package main
import (
"context"
"fmt"
"time"
)
//1. 使用chan创建
//2 run函数消费chan,做数据上报
//3 run函数交给调用者执行， run调用结束之后将stop发送信号， 当Shutdown时候可以同stop来知道他什么时候退出， 然后通过close(t.ch)，可以让整个RUN 的goroutine退出
// 重点
// 1.要搞清楚goroutine什么时候退出
// 2. 控制goroutine退出
// 3. 把并发给调用者
func main() {
tr := NewTracker()
// 1。 把并发行为给调用者
go tr.Run()
_ = tr.Event(context.Background(), "test")
_ = tr.Event(context.Background(), "test")
_ = tr.Event(context.Background(), "test")
ctx, cancel := context.WithDeadline(context.Background(), time.Now().Add(10*time.Second))
defer cancel()
tr.Shutdown(ctx)
}
func NewTracker() *Tracker {
return &Tracker{ch: make(chan string, 10)}
}
type Tracker struct {
ch chan string
stop chan struct{}
}
func (t *Tracker) Event(ctx context.Context, data string) error {
select {
case t.ch <- data:
return nil
case <-ctx.Done():
return ctx.Err()
}
}
func (t *Tracker) Run() {
for data := range t.ch {
time.Sleep(1 * time.Second)
fmt.Println(data)
}
t.stop <- struct{}{}
}
func (t *Tracker) Shutdown(ctx context.Context) {
close(t.ch) //可以让run的goroutine退出
select {
case <-t.stop:
case <-ctx.Done():
}
}