3.1 go context代碼示例

context.WithCancel
返回兩個有關聯的對象，ctx與cancel，調用cancel發送一個空struct給ctx，ctx一旦接收到該對象后，就終止goroutine的執行;
ctx是線程安全的，可以同時傳遞給多個goroutine，觸發cancel時，取消所有goroutine的執行

package mainimport ("context""fmt""time"
)func testContext(){ctx,cancel := context.WithCancel(context.Background())go d1(ctx)go d2(ctx)time.Sleep(7*time.Second)cancel()
}func d1(ctx context.Context){i:=0for {time.Sleep(1*time.Second)i++select {case <- ctx.Done():fmt.Println("d1 over")returndefault:fmt.Println("d1 ",i)}}
}func d2(ctx context.Context){fmt.Println("d2 start")<- ctx.Done()fmt.Println("d2 over")
}func main(){testContext()fmt.Println("main over")
}

輸出

d2 start
d1  1
d1  2
d1  3
d1  4
d1  5
d1  6
main over

context.WithTimeout

package mainimport ("fmt""context""time"
)func d1(ctx context.Context){i := 0for{time.Sleep(1*time.Second)select{case <- ctx.Done():fmt.Println("d1 over")returndefault:fmt.Println("d1:",i)}}
}func test(){ctx,cancel := context.WithTimeout(context.Background(),5*time.Second)go d1(ctx)fmt.Println("begin sleep 10 sec")time.Sleep(10*time.Second)fmt.Println("10 sec over")cancel()
}func main(){test()
}

[root@phoenix go]# go run cc.go 
begin sleep 10 sec
d1: 0
d1: 0
d1: 0
d1: 0
d1 over
10 sec over

　　

?