中級錯誤 · go

[TOC] # 關閉 HTTP 的響應體使用 HTTP 標準庫發起請求、獲取響應時，即使你不從響應中讀取任何數據或響應為空，都需要手動關閉響應體。新手很容易忘記手動關閉，或者寫在了錯誤的位置： ~~~ // 請求失敗造成 panic func main() { resp, err := http.Get("https://api.ipify.org?format=json") defer resp.Body.Close() // resp 可能為 nil，不能讀取 Body if err != nil { fmt.Println(err) return } body, err := ioutil.ReadAll(resp.Body) checkError(err) fmt.Println(string(body)) } func checkError(err error) { if err != nil{ log.Fatalln(err) } } ~~~ 上邊的代碼能正確發起請求，但是一旦請求失敗，變量`resp`值為`nil`，造成 panic： > panic: runtime error: invalid memory address or nil pointer dereference 應該先檢查 HTTP 響應錯誤為`nil`，再調用`resp.Body.Close()`來關閉響應體： ~~~ // 大多數情況正確的示例 func main() { resp, err := http.Get("https://api.ipify.org?format=json") checkError(err) defer resp.Body.Close() // 絕大多數情況下的正確關閉方式 body, err := ioutil.ReadAll(resp.Body) checkError(err) fmt.Println(string(body)) } ~~~ 輸出： > Get[https://api.ipify.org?format=...](https://api.ipify.org/?format=json): x509: certificate signed by unknown authority 絕大多數請求失敗的情況下，`resp`的值為`nil`且`err`為`non-nil`。但如果你得到的是重定向錯誤，那它倆的值都是`non-nil`，最后依舊可能發生內存泄露。2 個解決辦法： * 可以直接在處理 HTTP 響應錯誤的代碼塊中，直接關閉非 nil 的響應體。 * 手動調用`defer`來關閉響應體： ~~~ // 正確示例 func main() { resp, err := http.Get("http://www.baidu.com") // 關閉 resp.Body 的正確姿勢 if resp != nil { defer resp.Body.Close() } checkError(err) defer resp.Body.Close() body, err := ioutil.ReadAll(resp.Body) checkError(err) fmt.Println(string(body)) } ~~~ `resp.Body.Close()`早先版本的實現是讀取響應體的數據之后丟棄，保證了 keep-alive 的 HTTP 連接能重用處理不止一個請求。但 Go 的最新版本將讀取并丟棄數據的任務交給了用戶，如果你不處理，HTTP 連接可能會直接關閉而非重用，參考在 Go 1.5 版本文檔。如果程序大量重用 HTTP 長連接，你可能要在處理響應的邏輯代碼中加入： ~~~ _, err = io.Copy(ioutil.Discard, resp.Body)?// 手動丟棄讀取完畢的數據 ~~~ 如果你需要完整讀取響應，上邊的代碼是需要寫的。比如在解碼 API 的 JSON 響應數據： ~~~ json.NewDecoder(resp.Body).Decode(&data) ~~~ # 關閉HTTP連接一些支持 HTTP1.1 或 HTTP1.0 配置了`connection: keep-alive`選項的服務器會保持一段時間的長連接。但標準庫 "net/http" 的連接默認只在服務器主動要求關閉時才斷開，所以你的程序可能會消耗完 socket 描述符。解決辦法有 2 個，請求結束后： * 直接設置請求變量的`Close`字段值為`true`，每次請求結束后就會主動關閉連接。 * 設置 Header 請求頭部選項`Connection: close`，然后服務器返回的響應頭部也會有這個選項，此時 HTTP 標準庫會主動斷開連接。 ~~~ // 主動關閉連接 func main() { req, err := http.NewRequest("GET", "http://golang.org", nil) checkError(err) req.Close = true //req.Header.Add("Connection", "close") // 等效的關閉方式 resp, err := http.DefaultClient.Do(req) if resp != nil { defer resp.Body.Close() } checkError(err) body, err := ioutil.ReadAll(resp.Body) checkError(err) fmt.Println(string(body)) } ~~~ 你可以創建一個自定義配置的 HTTP transport 客戶端，用來取消 HTTP 全局的復用連接： ~~~ func main() { tr := http.Transport{DisableKeepAlives: true} client := http.Client{Transport: &tr} resp, err := client.Get("https://golang.google.cn/") if resp != nil { defer resp.Body.Close() } checkError(err) fmt.Println(resp.StatusCode) // 200 body, err := ioutil.ReadAll(resp.Body) checkError(err) fmt.Println(len(string(body))) } ~~~ 根據需求選擇使用場景： * 若你的程序要向同一服務器發大量請求，使用默認的保持長連接。 * 若你的程序要連接大量的服務器，且每臺服務器只請求一兩次，那收到請求后直接關閉連接。或增加最大文件打開數`fs.file-max`的值。 # 將 JSON 中的數字解碼為 interface 類型在 encode/decode JSON 數據時，Go 默認會將數值當做 float64 處理，比如下邊的代碼會造成 panic： ~~~ func main() { var data = []byte(`{"status": 200}`) var result map[string]interface{} if err := json.Unmarshal(data, &result); err != nil { log.Fatalln(err) } fmt.Printf("%T\n", result["status"]) // float64 var status = result["status"].(int) // 類型斷言錯誤 fmt.Println("Status value: ", status) } ~~~ > panic: interface conversion: interface {} is float64, not int 如果你嘗試 decode 的 JSON 字段是整型，你可以： * 將 int 值轉為 float 統一使用 * 將 decode 后需要的 float 值轉為 int 使用 ~~~ // 將 decode 的值轉為 int 使用 func main() { var data = []byte(`{"status": 200}`) var result map[string]interface{} if err := json.Unmarshal(data, &result); err != nil { log.Fatalln(err) } var status = uint64(result["status"].(float64)) fmt.Println("Status value: ", status) } ~~~ * 使用`Decoder`類型來 decode JSON 數據，明確表示字段的值類型 ~~~ // 指定字段類型 func main() { var data = []byte(`{"status": 200}`) var result map[string]interface{} var decoder = json.NewDecoder(bytes.NewReader(data)) decoder.UseNumber() if err := decoder.Decode(&result); err != nil { log.Fatalln(err) } var status, _ = result["status"].(json.Number).Int64() fmt.Println("Status value: ", status) } // 你可以使用 string 來存儲數值數據，在 decode 時再決定按 int 還是 float 使用 // 將數據轉為 decode 為 string func main() { var data = []byte({"status": 200}) var result map[string]interface{} var decoder = json.NewDecoder(bytes.NewReader(data)) decoder.UseNumber() if err := decoder.Decode(&result); err != nil { log.Fatalln(err) } var status uint64 err := json.Unmarshal([]byte(result["status"].(json.Number).String()), &status); checkError(err) fmt.Println("Status value: ", status) } ~~~ - 使用`struct`類型將你需要的數據映射為數值型 ~~~ // struct 中指定字段類型 func main() { var data = []byte(`{"status": 200}`) var result struct { Status uint64 `json:"status"` } err := json.NewDecoder(bytes.NewReader(data)).Decode(&result) checkError(err) fmt.Printf("Result: %+v", result) } ~~~ * 可以使用`struct`將數值類型映射為`json.RawMessage`原生數據類型適用于如果 JSON 數據不著急 decode 或 JSON 某個字段的值類型不固定等情況： ~~~ // 狀態名稱可能是 int 也可能是 string，指定為 json.RawMessage 類型 func main() { records := [][]byte{ []byte(`{"status":200, "tag":"one"}`), []byte(`{"status":"ok", "tag":"two"}`), } for idx, record := range records { var result struct { StatusCode uint64 StatusName string Status json.RawMessage `json:"status"` Tag string `json:"tag"` } err := json.NewDecoder(bytes.NewReader(record)).Decode(&result) checkError(err) var name string err = json.Unmarshal(result.Status, &name) if err == nil { result.StatusName = name } var code uint64 err = json.Unmarshal(result.Status, &code) if err == nil { result.StatusCode = code } fmt.Printf("[%v] result => %+v\n", idx, result) } } ~~~ # struct、array、slice 和 map 的值比較可以使用相等運算符`==`來比較結構體變量，前提是兩個結構體的成員都是可比較的類型： ~~~ type data struct { num int fp float32 complex complex64 str string char rune yes bool events <-chan string handler interface{} ref *byte raw [10]byte } func main() { v1 := data{} v2 := data{} fmt.Println("v1 == v2: ", v1 == v2) // true } ~~~ 如果兩個結構體中有任意成員是不可比較的，將會造成編譯錯誤。注意數組成員只有在數組元素可比較時候才可比較。 ~~~ type data struct { num int checks [10]func() bool // 無法比較 doIt func() bool // 無法比較 m map[string]string // 無法比較 bytes []byte // 無法比較 } func main() { v1 := data{} v2 := data{} fmt.Println("v1 == v2: ", v1 == v2) } ~~~ > invalid operation: v1 == v2 (struct containing \[10\]func() bool cannot be compared) Go 提供了一些庫函數來比較那些無法使用`==`比較的變量，比如使用 "reflect" 包的`DeepEqual()`： ~~~ // 比較相等運算符無法比較的元素 func main() { v1 := data{} v2 := data{} fmt.Println("v1 == v2: ", reflect.DeepEqual(v1, v2)) // true m1 := map[string]string{"one": "a", "two": "b"} m2 := map[string]string{"two": "b", "one": "a"} fmt.Println("v1 == v2: ", reflect.DeepEqual(m1, m2)) // true s1 := []int{1, 2, 3} s2 := []int{1, 2, 3} // 注意兩個 slice 相等，值和順序必須一致 fmt.Println("v1 == v2: ", reflect.DeepEqual(s1, s2)) // true } ~~~ 這種比較方式可能比較慢，根據你的程序需求來使用。`DeepEqual()`還有其他用法： ~~~ func main() { var b1 []byte = nil b2 := []byte{} fmt.Println("b1 == b2: ", reflect.DeepEqual(b1, b2)) // false } ~~~ **注意：** * `DeepEqual()`并不總適合于比較 slice ~~~ func main() { var str = "one" var in interface{} = "one" fmt.Println("str == in: ", reflect.DeepEqual(str, in)) // true v1 := []string{"one", "two"} v2 := []string{"two", "one"} fmt.Println("v1 == v2: ", reflect.DeepEqual(v1, v2)) // false data := map[string]interface{}{ "code": 200, "value": []string{"one", "two"}, } encoded, _ := json.Marshal(data) var decoded map[string]interface{} json.Unmarshal(encoded, &decoded) fmt.Println("data == decoded: ", reflect.DeepEqual(data, decoded)) // false } ~~~ 如果要大小寫不敏感來比較 byte 或 string 中的英文文本，可以使用 "bytes" 或 "strings" 包的`ToUpper()`和`ToLower()`函數。比較其他語言的 byte 或 string，應使用`bytes.EqualFold()`和`strings.EqualFold()` 如果 byte slice 中含有驗證用戶身份的數據（密文哈希、token 等），不應再使用`reflect.DeepEqual()`、`bytes.Equal()`、`bytes.Compare()`。這三個函數容易對程序造成[timing attacks](http://en.wikipedia.org/wiki/Timing_attack)，此時應使用 "crypto/subtle" 包中的`subtle.ConstantTimeCompare()`等函數 * `reflect.DeepEqual()`認為空 slice 與 nil slice 并不相等，但注意`byte.Equal()`會認為二者相等： ~~~ func main() { var b1 []byte = nil b2 := []byte{} // b1 與 b2 長度相等、有相同的字節序 // nil 與 slice 在字節上是相同的 fmt.Println("b1 == b2: ", bytes.Equal(b1, b2)) // true } ~~~ # 從 panic 中恢復在一個 defer 延遲執行的函數中調用`recover()`，它便能捕捉 / 中斷 panic ~~~ // 錯誤的 recover 調用示例 func main() { recover() // 什么都不會捕捉 panic("not good") // 發生 panic，主程序退出 recover() // 不會被執行 println("ok") } // 正確的 recover 調用示例 func main() { defer func() { fmt.Println("recovered: ", recover()) }() panic("not good") } ~~~ 從上邊可以看出，`recover()`僅在 defer 執行的函數中調用才會生效。 ~~~ // 錯誤的調用示例 func main() { defer func() { doRecover() }() panic("not good") } func doRecover() { fmt.Println("recobered: ", recover()) } ~~~ > recobered: panic: not good # 在 range 迭代 slice、array、map 時通過更新引用來更新元素在 range 迭代中，得到的值其實是元素的一份值拷貝，更新拷貝并不會更改原來的元素，即是拷貝的地址并不是原有元素的地址： ~~~ func main() { data := []int{1, 2, 3} for _, v := range data { v *= 10 // data 中原有元素是不會被修改的 } fmt.Println("data: ", data) // data: [1 2 3] } ~~~ 如果要修改原有元素的值，應該使用索引直接訪問： ~~~ func main() { data := []int{1, 2, 3} for i, v := range data { data[i] = v * 10 } fmt.Println("data: ", data) // data: [10 20 30] } ~~~ 如果你的集合保存的是指向值的指針，需稍作修改。依舊需要使用索引訪問元素，不過可以使用 range 出來的元素直接更新原有值： ~~~ func main() { data := []*struct{ num int }{{1}, {2}, {3},} for _, v := range data { v.num *= 10 // 直接使用指針更新 } fmt.Println(data[0], data[1], data[2]) // &{10} &{20} &{30} } ~~~ # slice 中隱藏的數據從 slice 中重新切出新 slice 時，新 slice 會引用原 slice 的底層數組。如果跳了這個坑，程序可能會分配大量的臨時 slice 來指向原底層數組的部分數據，將導致難以預料的內存使用。 ~~~ func get() []byte { raw := make([]byte, 10000) fmt.Println(len(raw), cap(raw), &raw[0]) // 10000 10000 0xc420080000 return raw[:3] // 重新分配容量為 10000 的 slice } func main() { data := get() fmt.Println(len(data), cap(data), &data[0]) // 3 10000 0xc420080000 } ~~~ 可以通過拷貝臨時 slice 的數據，而不是重新切片來解決： ~~~ func get() (res []byte) { raw := make([]byte, 10000) fmt.Println(len(raw), cap(raw), &raw[0]) // 10000 10000 0xc420080000 res = make([]byte, 3) copy(res, raw[:3]) return } func main() { data := get() fmt.Println(len(data), cap(data), &data[0]) // 3 3 0xc4200160b8 } ~~~ # Slice 中數據的誤用舉個簡單例子，重寫文件路徑（存儲在 slice 中）分割路徑來指向每個不同級的目錄，修改第一個目錄名再重組子目錄名，創建新路徑： ~~~ // 錯誤使用 slice 的拼接示例 func main() { path := []byte("AAAA/BBBBBBBBB") sepIndex := bytes.IndexByte(path, '/') // 4 println(sepIndex) dir1 := path[:sepIndex] dir2 := path[sepIndex+1:] println("dir1: ", string(dir1)) // AAAA println("dir2: ", string(dir2)) // BBBBBBBBB dir1 = append(dir1, "suffix"...) println("current path: ", string(path)) // AAAAsuffixBBBB path = bytes.Join([][]byte{dir1, dir2}, []byte{'/'}) println("dir1: ", string(dir1)) // AAAAsuffix println("dir2: ", string(dir2)) // uffixBBBB println("new path: ", string(path)) // AAAAsuffix/uffixBBBB // 錯誤結果 } ~~~ 拼接的結果不是正確的`AAAAsuffix/BBBBBBBBB`，因為 dir1、 dir2 兩個 slice 引用的數據都是`path`的底層數組，第 13 行修改`dir1`同時也修改了`path`，也導致了`dir2`的修改解決方法： * 重新分配新的 slice 并拷貝你需要的數據 * 使用完整的 slice 表達式：`input[low:high:max]`，容量便調整為 max - low ~~~ // 使用 full slice expression func main() { path := []byte("AAAA/BBBBBBBBB") sepIndex := bytes.IndexByte(path, '/') // 4 dir1 := path[:sepIndex:sepIndex] // 此時 cap(dir1) 指定為4，而不是先前的 16 dir2 := path[sepIndex+1:] dir1 = append(dir1, "suffix"...) path = bytes.Join([][]byte{dir1, dir2}, []byte{'/'}) println("dir1: ", string(dir1)) // AAAAsuffix println("dir2: ", string(dir2)) // BBBBBBBBB println("new path: ", string(path)) // AAAAsuffix/BBBBBBBBB } ~~~ 第 6 行中第三個參數是用來控制 dir1 的新容量，再往 dir1 中 append 超額元素時，將分配新的 buffer 來保存。而不是覆蓋原來的 path 底層數組 # 舊 slice 當你從一個已存在的 slice 創建新 slice 時，二者的數據指向相同的底層數組。如果你的程序使用這個特性，那需要注意 "舊"（stale） slice 問題。某些情況下，向一個 slice 中追加元素而它指向的底層數組容量不足時，將會重新分配一個新數組來存儲數據。而其他 slice 還指向原來的舊底層數組。 ~~~ // 超過容量將重新分配數組來拷貝值、重新存儲 func main() { s1 := []int{1, 2, 3} fmt.Println(len(s1), cap(s1), s1) // 3 3 [1 2 3 ] s2 := s1[1:] fmt.Println(len(s2), cap(s2), s2) // 2 2 [2 3] for i := range s2 { s2[i] += 20 } // 此時的 s1 與 s2 是指向同一個底層數組的 fmt.Println(s1) // [1 22 23] fmt.Println(s2) // [22 23] s2 = append(s2, 4) // 向容量為 2 的 s2 中再追加元素，此時將分配新數組來存 for i := range s2 { s2[i] += 10 } fmt.Println(s1) // [1 22 23] // 此時的 s1 不再更新，為舊數據 fmt.Println(s2) // [32 33 14] } ~~~ # 類型聲明與方法從一個現有的非 interface 類型創建新類型時，并不會繼承原有的方法： ~~~ // 定義 Mutex 的自定義類型 type myMutex sync.Mutex func main() { var mtx myMutex mtx.Lock() mtx.UnLock() } ~~~ > mtx.Lock undefined (type myMutex has no field or method Lock)... 如果你需要使用原類型的方法，可將原類型以匿名字段的形式嵌到你定義的新 struct 中： ~~~ // 類型以字段形式直接嵌入 type myLocker struct { sync.Mutex } func main() { var locker myLocker locker.Lock() locker.Unlock() } ~~~ interface 類型聲明也保留它的方法集： ~~~ type myLocker sync.Locker func main() { var locker myLocker locker.Lock() locker.Unlock() } ~~~ # 跳出 for-switch 和 for-select 代碼塊沒有指定標簽的 break 只會跳出 switch/select 語句，若不能使用 return 語句跳出的話，可為 break 跳出標簽指定的代碼塊： ~~~ // break 配合 label 跳出指定代碼塊 func main() { loop: for { switch { case true: fmt.Println("breaking out...") //break // 死循環，一直打印 breaking out... break loop } } fmt.Println("out...") } ~~~ `goto`雖然也能跳轉到指定位置，但依舊會再次進入 for-switch，死循環。 # for 語句中的迭代變量與閉包函數 for 語句中的迭代變量在每次迭代中都會重用，即 for 中創建的閉包函數接收到的參數始終是同一個變量，在 goroutine 開始執行時都會得到同一個迭代值： ~~~ func main() { data := []string{"one", "two", "three"} for _, v := range data { go func() { fmt.Println(v) }() } time.Sleep(3 * time.Second) // 輸出 three three three } ~~~ 最簡單的解決方法：無需修改 goroutine 函數，在 for 內部使用局部變量保存迭代值，再傳參： ~~~ func main() { data := []string{"one", "two", "three"} for _, v := range data { vCopy := v go func() { fmt.Println(vCopy) }() } time.Sleep(3 * time.Second) // 輸出 one two three } ~~~ 另一個解決方法：直接將當前的迭代值以參數形式傳遞給匿名函數： ~~~ func main() { data := []string{"one", "two", "three"} for _, v := range data { go func(in string) { fmt.Println(in) }(v) } time.Sleep(3 * time.Second) // 輸出 one two three } ~~~ 注意下邊這個稍復雜的 3 個示例區別： ~~~ type field struct { name string } func (p *field) print() { fmt.Println(p.name) } // 錯誤示例 func main() { data := []field{{"one"}, {"two"}, {"three"}} for _, v := range data { go v.print() } time.Sleep(3 * time.Second) // 輸出 three three three } // 正確示例 func main() { data := []field{{"one"}, {"two"}, {"three"}} for _, v := range data { v := v go v.print() } time.Sleep(3 * time.Second) // 輸出 one two three } // 正確示例 func main() { data := []*field{{"one"}, {"two"}, {"three"}} for _, v := range data { // 此時迭代值 v 是三個元素值的地址，每次 v 指向的值不同 go v.print() } time.Sleep(3 * time.Second) // 輸出 one two three } ~~~ # defer 函數的參數值對 defer 延遲執行的函數，它的參數會在聲明時候就會求出具體值，而不是在執行時才求值： ~~~ // 在 defer 函數中參數會提前求值 func main() { var i = 1 defer fmt.Println("result: ", func() int { return i * 2 }()) i++ } ~~~ > result: 2 # defer 函數的執行時機對 defer 延遲執行的函數，會在調用它的函數結束時執行，而不是在調用它的語句塊結束時執行，注意區分開。比如在一個長時間執行的函數里，內部 for 循環中使用 defer 來清理每次迭代產生的資源調用，就會出現問題： ~~~ // 命令行參數指定目錄名 // 遍歷讀取目錄下的文件 func main() { if len(os.Args) != 2 { os.Exit(1) } dir := os.Args[1] start, err := os.Stat(dir) if err != nil || !start.IsDir() { os.Exit(2) } var targets []string filepath.Walk(dir, func(fPath string, fInfo os.FileInfo, err error) error { if err != nil { return err } if !fInfo.Mode().IsRegular() { return nil } targets = append(targets, fPath) return nil }) for _, target := range targets { f, err := os.Open(target) if err != nil { fmt.Println("bad target:", target, "error:", err) //error:too many open files break } defer f.Close() // 在每次 for 語句塊結束時，不會關閉文件資源 // 使用 f 資源 } } ~~~ 先創建 10000 個文件： ~~~ #!/bin/bash for n in {1..10000}; do echo content > "file${n}.txt" done ~~~ 運行效果： ![](https://img.kancloud.cn/2e/07/2e07e58d6c1a9b559204ee5021b282d7_475x120.png) 解決辦法：defer 延遲執行的函數寫入匿名函數中： ~~~ // 目錄遍歷正常 func main() { // ... for _, target := range targets { func() { f, err := os.Open(target) if err != nil { fmt.Println("bad target:", target, "error:", err) return // 在匿名函數內使用 return 代替 break 即可 } defer f.Close() // 匿名函數執行結束，調用關閉文件資源 // 使用 f 資源 }() } } ~~~ 當然你也可以去掉 defer，在文件資源使用完畢后，直接調用`f.Close()`來關閉。 # 失敗的類型斷言在類型斷言語句中，斷言失敗則會返回目標類型的“零值”，斷言變量與原來變量混用可能出現異常情況： ~~~ // 錯誤示例 func main() { var data interface{} = "great" // data 混用 if data, ok := data.(int); ok { fmt.Println("[is an int], data: ", data) } else { fmt.Println("[not an int], data: ", data) // [isn't a int], data: 0 } } // 正確示例 func main() { var data interface{} = "great" if res, ok := data.(int); ok { fmt.Println("[is an int], data: ", res) } else { fmt.Println("[not an int], data: ", data) // [not an int], data: great } } ~~~ # 阻塞的 gorutinue 與資源泄露在 2012 年 Google I/O 大會上，Rob Pike 的[Go Concurrency Patterns](https://talks.golang.org/2012/concurrency.slide#1)演講討論 Go 的幾種基本并發模式，如[完整代碼](https://repl.it/@pllv/Google-Search-Gorountine-Parallel-Replicas-Rob-Pike)中從數據集中獲取第一條數據的函數： ~~~ func First(query string, replicas []Search) Result { c := make(chan Result) replicaSearch := func(i int) { c <- replicas[i](query) } for i := range replicas { go replicaSearch(i) } return <-c } ~~~ 在搜索重復時依舊每次都起一個 goroutine 去處理，每個 goroutine 都把它的搜索結果發送到結果 channel 中，channel 中收到的第一條數據會直接返回。返回完第一條數據后，其他 goroutine 的搜索結果怎么處理？他們自己的協程如何處理？在`First()`中的結果 channel 是無緩沖的，這意味著只有第一個 goroutine 能返回，由于沒有 receiver，其他的 goroutine 會在發送上一直阻塞。如果你大量調用，則可能造成資源泄露。為避免泄露，你應該確保所有的 goroutine 都能正確退出，有 2 個解決方法： * 使用帶緩沖的 channel，確保能接收全部 goroutine 的返回結果： ~~~ func First(query string, replicas ...Search) Result { c := make(chan Result,len(replicas)) searchReplica := func(i int) { c <- replicas[i](query) } for i := range replicas { go searchReplica(i) } return <-c } ~~~ * 使用`select`語句，配合能保存一個緩沖值的 channel`default`語句： `default`的緩沖 channel 保證了即使結果 channel 收不到數據，也不會阻塞 goroutine ~~~ func First(query string, replicas ...Search) Result { c := make(chan Result,1) searchReplica := func(i int) { select { case c <- replicas[i](query): default: } } for i := range replicas { go searchReplica(i) } return <-c } ~~~ * 使用特殊的廢棄（cancellation） channel 來中斷剩余 goroutine 的執行： ~~~ func First(query string, replicas ...Search) Result { c := make(chan Result) done := make(chan struct{}) defer close(done) searchReplica := func(i int) { select { case c <- replicas[i](query): case <- done: } } for i := range replicas { go searchReplica(i) } return <-c } ~~~ Rob Pike 為了簡化演示，沒有提及演講代碼中存在的這些問題。不過對于新手來說，可能會不加思考直接使用。