Go併發程式設計 select的使用

本文描述了select的用法，通過select可以監聽多個channel的讀寫事件。這很類似於linux系統程式設計的select函式。但在go中，實現的機制明顯是不同的。linux系統程式設計的select是輪訓的機制，而且監控的是檔案描述符，且有數量的限制。go中的select和channel配合使用，監控的是channel的讀寫狀態。

var c1, c2 <-chan
inte***ce{}
var c3 chan
<- inte***ce{}
select {}: //監控channel的寫事件
// do something
}

func testselect1() )
go func() ()
fmt.println("blocking on read...")
select 
}

注意：當close channel時，讀取channel的一方會從channel中讀取到value,false，此時的value一般情況下為nil。

該例子也可以用來通知當不使用channel時，關閉channel的情況。

當多個channel同時準備好，select的行為是怎樣的呢？我們通過乙個例子來看一下：

func testmultichannel() ); close(c1)
c2 := make(chan
inte***ce{}); close(c2)
c3 := make(chan
inte***ce{}); close(c3)
var c1count, c2count, c3count int
for i :=1000; i >=0; i-- 
}fmt.printf("c1count: %d\nc2count: %d\nc3count: %d\n", c1count, c2count, c3count)
}

輸出：

c1count: 337 c2count: 319

c3count: 345

多執行幾次，可以看出，幾個數字相差都不是很大。

以上例子，同時有3個channel可讀取，從以上的輸出可以看出，select對多個channel的讀取排程是基本公平的。讓每乙個channel的資料都有機會被處理。

在很多情況下，當channel沒有準備好時，我們希望能夠設定乙個超時時間，並在等待channel超時時進行一些處理。此時就可以按以下方式來進行編碼：

func testproctimeout() 
}}

該**會每隔1秒鐘，列印出：

timed out.do something. timed out.do something. timed out.do something.

...

這樣select就變成了「非阻塞」模式，我們可以設定乙個時間，當沒有channel可處理時，可以處理超時時間。這也是後台伺服器程式設計常用的處理方式。

當沒有任何channel準備好資料時，可以設定是執行預設的處理**。

func testdefaultproc() 
}

注意：default和處理超時不同，當沒有channel可讀取時，會立即執行default分支。而超時的處理，必須要等到超時，才處理。

func testexitloop() )
gofunc() ()
workcounter :=0
loop:
for 
// simulate work
workcounter++
time.sleep(1*time.second)
}fmt.printf("在通知退出迴圈時，執行了%d次.\n", workcounter)
}

啟動乙個goroutine，該goroutine在2s後，關閉channel。此時，主協程會在select中的case <-done分支中得到通知，跳出死迴圈。而在此之前，會執行default分支的**，這裡是什麼都不做。

select{}

以上的語句會永遠等待，直到有訊號中斷。

本文總結了select+channel模式的特點和各種用法，可以針對具體情況選擇使用相應的模式。

Go併發程式設計 select的使用

Go 併發程式設計

go併發程式設計

Go併發程式設計實踐

Go併發程式設計 select的使用

Go 併發程式設計

go併發程式設計

Go併發程式設計實踐

相關推薦