var ch1 chan int
var ch2 chan int
<br>// 任務(wù)A， 通過最外層的for來控制定期執(zhí)行
func TestMe(t *testing.T) {
    ch1 = make(chan int, 0)
    ch2 = make(chan int, 0)
    count := 0
    for {
        count ++
        ctx, cancel := context.WithTimeout(context.Background(), time.Second * 2)<br>                // 任務(wù)A的邏輯部分，開啟子任務(wù)B, C。<br>                // B,C通過ch1，ch2和A通信。<br>                // 同時(shí)監(jiān)聽ctx.Done，如果超時(shí)了立即結(jié)束本次任務(wù)不繼續(xù)執(zhí)行
        go func(ctx context.Context) {
            go g1(ctx, count)
            go g2(ctx, count)
            v1, v2 := -1, -1
            for v1 == -1 || v2 == -1 {
                select {
                case <- ctx.Done():
                    cancel()
                    fmt.Println("父級(jí)2超時(shí)退出，當(dāng)前count值為", count, "當(dāng)前時(shí)間：", time.Now())
                    return
                case v1 = <- ch1:
                case v2 = <- ch2:
                }
            }
            fmt.Println("正常執(zhí)行完成退出, 開啟下次循環(huán)，當(dāng)前count值為：", count, "當(dāng)前 v1: ", v1, "當(dāng)前 v2: ", v2)
        }(ctx)<br>                // 任務(wù)A監(jiān)控ctx是否到達(dá)timeOUT，timeout就終止本次執(zhí)行
        select {
        case <- ctx.Done():
            fmt.Println("父級(jí)1超時(shí)退出，當(dāng)前count值為", count, "當(dāng)前時(shí)間：", time.Now())
        }
        time.Sleep(time.Second * 3)
    }
}
<br>// 改進(jìn)后的任務(wù)B，即使計(jì)算出了結(jié)果，也不會(huì)再向ch1寫數(shù)據(jù)了，不會(huì)造成臟數(shù)據(jù)
func g1 (ctx context.Context, num int) {
    fmt.Println("g1 num", num, "time", time.Now())
    select {
    case <-ctx.Done():
        fmt.Println("子級(jí) g1關(guān)閉, 不向channel中寫數(shù)據(jù)")
        return
    default:
        ch1 <- num
    }
}
<br>// 改進(jìn)前的任務(wù)C
func g2 (ctx context.Context, num int) {
    fmt.Println("g2 num", num, "time", time.Now())
    ch2 <- num

// 在第3次任務(wù)重等待3s, 使得它超時(shí)<br>func g2 (ctx context.Context, num int) {
    if num == 3 {
        time.Sleep(time.Second * 3)
    }
    fmt.Println("g2 num", num, "time", time.Now())
    ch2 <- num
}

func g2 (ctx context.Context, num int) {
    if num == 3 {
        time.Sleep(time.Second * 10)
        fmt.Println("這次g2 超時(shí)，應(yīng)當(dāng)g1, g2都不返回")
    }
    fmt.Println("g2 num", num, "time", time.Now())
    select {
    case <-ctx.Done():
        fmt.Println("子級(jí) g2關(guān)閉, 不向channel中寫數(shù)據(jù)")
        return
    default:
        ch2 <- num
    }
}