func TestChanCloseGoroutine(t *testing.T) {
	fmt.Printf("開(kāi)始了，有%d個(gè)協(xié)程\n", runtime.NumGoroutine())

	var (
		chB  = make(chan struct{})
		chB1 = make(chan struct{})
		chB2 = make(chan struct{})
		chC  = make(chan struct{})
	)

	// 協(xié)程A
	go func() {
		// 協(xié)程B
		go func() {
			// 協(xié)程B1
			go func() {
				for {
					select {
					case <-chB1:
						return
					default:
					}
				}
			}()
			// 協(xié)程B2
			go func() {
				// 協(xié)程C
				go func() {
					for {
						select {
						case <-chC:
							return
						default:
						}
					}
				}()
				for {
					select {
					case <-chB2:
						// 通知協(xié)程C退出
						chC <- struct{}{}
						return
					default:
					}
				}
			}()

			for {
				select {
				case <-chB:
					chB1 <- struct{}{}
					chB2 <- struct{}{}
					return
				default:
				}
			}
		}()

		// 1秒后通知B退出
		time.Sleep(1 * time.Second)
		chB <- struct{}{}
		// A后續(xù)沒(méi)有任務(wù)了，會(huì)自動(dòng)退出
	}()

	time.Sleep(2 * time.Second)
	fmt.Printf("最終結(jié)束，有%d個(gè)協(xié)程\n", runtime.NumGoroutine())
}


// 結(jié)果
開(kāi)始了，有2個(gè)協(xié)程
最終結(jié)束，有2個(gè)協(xié)程
// tips: Go Test 會(huì)啟動(dòng)兩個(gè)額外的 goroutine 來(lái)運(yùn)行代碼，所以初始就會(huì)有2個(gè) goroutine

type Context interface {
	Deadline() (deadline time.Time, ok bool)
	Done() <-chan struct{}
	Err() error
	Value(key any) any
}

type emptyCtx int

func (*emptyCtx) Deadline() (deadline time.Time, ok bool) {
	return
}

func (*emptyCtx) Done() <-chan struct{} {
	return nil
}

func (*emptyCtx) Err() error {
	return nil
}

func (*emptyCtx) Value(key any) any {
	return nil
}

ctx := context.Background()
ctx := context.TODO()

var (
	background = new(emptyCtx)
	todo       = new(emptyCtx)
)

func Background() Context {
	return background
}

func TODO() Context {
	return todo
}

func TestCtxWithCancel(t *testing.T) {
	ctx := context.Background()
	ctx, cancel := context.WithCancel(ctx)
	go func() {
		for {
			select {
			// 還記得前文提到的Done的方法嗎
			// 當(dāng) ctx 取消時(shí)，ctx.Done()對(duì)應(yīng)的通道就會(huì)關(guān)閉，case也就會(huì)被執(zhí)行
			case <-ctx.Done():
				// ctx.Err() 會(huì)獲取到關(guān)閉原因哦
				fmt.Println("協(xié)程關(guān)閉", ctx.Err())
				return
			default:
				fmt.Println("繼續(xù)運(yùn)行")
				time.Sleep(100 * time.Millisecond)
			}
		}
	}()

	// 等待一秒后關(guān)閉
	time.Sleep(1 * time.Second)
	cancel()
	// 等待一秒，讓子協(xié)程有時(shí)間打印出協(xié)程關(guān)閉的原因
	time.Sleep(1 * time.Second)
}

// 結(jié)果
繼續(xù)運(yùn)行
繼續(xù)運(yùn)行
……
協(xié)程關(guān)閉 context canceled

func TestCtxWithDeadline(t *testing.T) {
	ctx := context.Background()
	// 等待2秒后自動(dòng)關(guān)閉
	ctx, cancel := context.WithDeadline(ctx, time.Now().Add(2*time.Second))
	defer cancel()
	// Deadline 前文也提到了，還記得嗎？用來(lái)獲取當(dāng)前任務(wù)的截至?xí)r間
	if t, ok := ctx.Deadline(); ok {
		// time.DateTime 是 go1.20 版本的一個(gè)常量，其值是："2006-01-02 15:04:05"
		fmt.Println(t.Format(time.DateTime))
	}
	go func() {
		select {
		case <-ctx.Done():
			// 手動(dòng)關(guān)閉 context canceled
			// 自動(dòng)關(guān)閉 context deadline exceeded
			fmt.Println("協(xié)程關(guān)閉", ctx.Err())
			return
		}
	}()

	time.Sleep(3 * time.Second)
}
// 結(jié)果
2023-05-10 18:00:36
協(xié)程關(guān)閉 context deadline exceeded


// 將最后的等待時(shí)間更改為一秒
func TestCtxWithDeadline(t *testing.T) {
	……
	time.Sleep(1 * time.Second)
}
// 結(jié)果
2023-05-10 18:01:45
協(xié)程關(guān)閉 context canceled

func TestCtxWithTimeout(t *testing.T) {
	ctx := context.Background()
	ctx, cancel := context.WithTimeout(ctx, 2*time.Second)
	defer cancel()
	go func() {
		select {
		case <-ctx.Done():
			fmt.Println("協(xié)程關(guān)閉", ctx.Err())
			return
		}
	}()

	time.Sleep(3 * time.Second)
}

// 結(jié)果
協(xié)程關(guān)閉 context deadline exceeded

// 向上找到最近的上下文值
func TestCtxWithValue(t *testing.T) {
	ctx := context.Background()
	ctx1 := context.WithValue(ctx, "key", "ok")
	ctx2, _ := context.WithCancel(ctx1)
	// Value 會(huì)一直向上追溯到根節(jié)點(diǎn)，獲取當(dāng)前上下文攜帶的值，
	value := ctx2.Value("key")
	if value != nil {
		fmt.Println(value)
	}
}

// 結(jié)果
ok

func TestCtxCloseGoroutine(t *testing.T) {
	fmt.Printf("開(kāi)始了，有%d個(gè)協(xié)程\n", runtime.NumGoroutine())

	ctx := context.Background()

	// 協(xié)程A
	go func(ctx context.Context) {
		ctx, cancel := context.WithCancel(ctx)
		// 協(xié)程B
		go func(ctx context.Context) {
			// 協(xié)程B1
			go func(ctx context.Context) {
				for {
					select {
					case <-ctx.Done():
						return
					default:
					}
				}
			}(ctx)
			// 協(xié)程B2
			go func(ctx context.Context) {
				// 協(xié)程C
				go func(ctx context.Context) {
					for {
						select {
						case <-ctx.Done():
							return
						default:
						}
					}
				}(ctx)
				for {
					select {
					case <-ctx.Done():
						return
					default:
					}
				}
			}(ctx)

			for {
				select {
				case <-ctx.Done():
					return
				default:
				}
			}
		}(ctx)

		// 1秒后通知退出
		time.Sleep(1 * time.Second)
		cancel()
		// A后續(xù)沒(méi)有任務(wù)了，會(huì)自動(dòng)退出
	}(ctx)

	time.Sleep(2 * time.Second)
	fmt.Printf("最終結(jié)束，有%d個(gè)協(xié)程\n", runtime.NumGoroutine())
}

// 結(jié)果
開(kāi)始了，有2個(gè)協(xié)程
最終結(jié)束，有2個(gè)協(xié)程