鍦℅o骞跺彂寮忕紪绋嬩腑锛屽彲浠ヤ娇鐢╯elect璇彞鏉ュ悓鏃剁洃鍚涓€氶亾鐨勬暟鎹祦鍔紝骞舵牴鎹笉鍚岀殑鎯呭喌杩涜澶勭悊銆傚綋涓€涓垨澶氫釜閫氶亾鏈夋暟鎹彲璇绘椂锛宻elect璇彞浼氶殢鏈洪€夋嫨涓€涓猚ase鏉ユ墽琛屻€?/p>

鍦ㄥ鐞嗛敊璇椂锛屽彲浠ュ皢閿欒淇℃伅鍙戦€佸埌涓€涓笓闂ㄧ殑閿欒閫氶亾锛屽苟鍦╯elect璇彞涓坊鍔犱竴涓猚ase鏉ュ鐞嗛敊璇€?/p>

涓嬮潰鏄竴涓ず渚嬩唬鐮侊細

package main
import (
"fmt"
"time"
)
func doWork(input chan string, errCh chan error) {
// 妯℃嫙涓€涓伐浣滀换鍔?/span>
time.Sleep(2 * time.Second)
// 鍋囪鍦ㄨ繖閲屽彂鐢熶簡涓€涓敊璇?/span>
err := fmt.Errorf("something went wrong")
errCh <- err
}
func main() {
input := make(chan string)
errCh := make(chan error)
go doWork(input, errCh)
select {
case <-input:
// 澶勭悊杈撳叆鏁版嵁
fmt.Println("Received input data")
case err := <-errCh:
// 澶勭悊閿欒
fmt.Println("Received error:", err)
}
}

鍦ㄨ繖涓緥瀛愪腑锛?code>doWork鍑芥暟妯℃嫙浜嗕竴涓伐浣滀换鍔★紝鍦ㄤ换鍔″畬鎴愬悗鍚?code>input閫氶亾鍙戦€佷簡涓€涓暟鎹€傜劧鍚庯紝鍦?code>doWork鍑芥暟涓彂鐢熶簡涓€涓敊璇紝骞跺皢閿欒淇℃伅閫氳繃errCh閫氶亾浼犻€掑嚭鏉ャ€?/p>

鍦?code>main鍑芥暟涓紝閫氳繃select璇彞鐩戝惉input鍜?code>errCh閫氶亾銆傚鏋?code>input閫氶亾鏈夋暟鎹彲璇伙紝鍒欏鐞嗚緭鍏ユ暟鎹紝鍚﹀垯濡傛灉errCh閫氶亾鏈夐敊璇俊鎭彲璇伙紝鍒欏鐞嗛敊璇€?/p>

闇€瑕佹敞鎰忕殑鏄紝鍦?code>doWork鍑芥暟涓紝濡傛灉娌℃湁鍙戠敓閿欒锛屽彲浠ラ€夋嫨灏?code>nil鍊煎彂閫佸埌errCh閫氶亾锛岃〃绀烘病鏈夐敊璇彂鐢熴€?/p>

杩欑鏂规硶鍙互鍦℅o骞跺彂寮忕紪绋嬩腑杩涜閿欒澶勭悊锛岄伩鍏嶄簡闃诲鍜屾閿佺殑闂锛屽苟涓旇兘澶熷悓鏃跺鐞嗕笉鍚岄€氶亾鐨勬暟鎹拰閿欒銆?/p>