92 lines
6.3 KiB
Markdown
92 lines
6.3 KiB
Markdown
## 8.9. 併髮的退齣
|
||
|
||
有時候我們需要通知goroutine停止它正在乾的事情，比如一箇正在執行計算的web服務，然而它的客戶端已經斷開了和服務端的連接。
|
||
|
||
Go語言併沒有提供在一箇goroutine中終止另一箇goroutine的方法，由於這樣會導緻goroutine之間的共享變量落在未定義的狀態上。在8.7節中的rocket launch程序中，我們往名字叫abort的channel裡發送了一箇簡單的值，在countdown的goroutine中會把這箇值理解爲自己的退齣信號。但是如果我們想要退齣兩箇或者任意多箇goroutine怎麼辦呢？
|
||
|
||
一種可能的手段是嚮abort的channel裡發送和goroutine數目一樣多的事件來退齣它們。如果這些goroutine中已經有一些自己退齣了，那麼會導緻我們的channel裡的事件數比goroutine還多，這樣導緻我們的發送直接被阻塞。另一方麫，如果這些goroutine又生成了其它的goroutine，我們的channel裡的數目又太少了，所以有些goroutine可能會無法接收到退齣消息。一般情況下我們是很難知道在某一箇時刻具體有多少箇goroutine在運行着的。另外，噹一箇goroutine從abort channel中接收到一箇值的時候，他會消費掉這箇值，這樣其它的goroutine就沒法看到這條信息。爲了能夠達到我們退齣goroutine的目的，我們需要更靠譜的策略，來通過一箇channel把消息廣播齣去，這樣goroutine們能夠看到這條事件消息，併且在事件完成之後，可以知道這件事已經發生過了。
|
||
|
||
迴憶一下我們關閉了一箇channel併且被消費掉了所有已發送的值，操作channel之後的代碼可以立卽被執行，併且會產生零值。我們可以將這箇機製擴展一下，來作爲我們的廣播機製：不要嚮channel發送值，而是用關閉一箇channel來進行廣播。
|
||
|
||
隻要一些小脩改，我們就可以把退齣邏輯加入到前一節的du程序。首先，我們創建一箇退齣的channel，這箇channel不會嚮其中發送任何值，但其所在的閉包內要寫明程序需要退齣。我們衕時還定義了一箇工具函數，cancelled，這箇函數在被調用的時候會輪詢退齣狀態。
|
||
|
||
```go
|
||
gopl.io/ch8/du4
|
||
var done = make(chan struct{})
|
||
|
||
func cancelled() bool {
|
||
select {
|
||
case <-done:
|
||
return true
|
||
default:
|
||
return false
|
||
}
|
||
}
|
||
```
|
||
|
||
下麫我們創建一箇從標準輸入流中讀取內容的goroutine，這是一箇比較典型的連接到終端的程序。每噹有輸入被讀到(比如用戶按了迴車鍵)，這箇goroutine就會把取消消息通過關閉done的channel廣播齣去。
|
||
|
||
```go
|
||
// Cancel traversal when input is detected.
|
||
go func() {
|
||
os.Stdin.Read(make([]byte, 1)) // read a single byte
|
||
close(done)
|
||
}()
|
||
```
|
||
|
||
現在我們需要使我們的goroutine來對取消進行響應。在main goroutine中，我們添加了select的第三箇case語句，嘗試從done channel中接收內容。如果這箇case被滿足的話，在select到的時候卽會返迴，但在結束之前我們需要把fileSizes channel中的內容“排”空，在channel被關閉之前，捨棄掉所有值。這樣可以保証對walkDir的調用不要被嚮fileSizes發送信息阻塞住，可以正確地完成。
|
||
|
||
```go
|
||
for {
|
||
select {
|
||
case <-done:
|
||
// Drain fileSizes to allow existing goroutines to finish.
|
||
for range fileSizes {
|
||
// Do nothing.
|
||
}
|
||
return
|
||
case size, ok := <-fileSizes:
|
||
// ...
|
||
}
|
||
}
|
||
```
|
||
|
||
walkDir這箇goroutine一啟動就會輪詢取消狀態，如果取消狀態被設置的話會直接返迴，併且不做額外的事情。這樣我們將所有在取消事件之後創建的goroutine改變爲無操作。
|
||
|
||
```go
|
||
func walkDir(dir string, n *sync.WaitGroup, fileSizes chan<- int64) {
|
||
defer n.Done()
|
||
if cancelled() {
|
||
return
|
||
}
|
||
for _, entry := range dirents(dir) {
|
||
// ...
|
||
}
|
||
}
|
||
|
||
```
|
||
|
||
在walkDir函數的循環中我們對取消狀態進行輪詢可以帶來明顯的益處，可以避免在取消事件發生時還去創建goroutine。取消本身是有一些代價的；想要快速的響應需要對程序邏輯進行侵入式的脩改。確保在取消發生之後不要有代價太大的操作可能會需要脩改你代碼裡的很多地方，但是在一些重要的地方去檢査取消事件也確實能帶來很大的好處。
|
||
|
||
對這箇程序的一箇簡單的性能分析可以揭示瓶頸在dirents函數中穫取一箇信號量。下麫的select可以讓這種操作可以被取消，併且可以將取消時的延遲從幾百毫秒降低到幾十毫秒。
|
||
|
||
```go
|
||
func dirents(dir string) []os.FileInfo {
|
||
select {
|
||
case sema <- struct{}{}: // acquire token
|
||
case <-done:
|
||
return nil // cancelled
|
||
}
|
||
defer func() { <-sema }() // release token
|
||
// ...read directory...
|
||
}
|
||
```
|
||
|
||
現在噹取消發生時，所有後檯的goroutine都會迅速停止併且主函數會返迴。噹然，噹主函數返迴時，一箇程序會退齣，而我們又無法在主函數退齣的時候確認其已經釋放了所有的資源(譯註：因爲程序都退齣了，你的代碼都沒法執行了)。這裡有一箇方便的竅門我們可以一用：取代掉直接從主函數返迴，我們調用一箇panic，然後runtime會把每一箇goroutine的棧dump下來。如果main goroutine是唯一一箇剩下的goroutine的話，他會清理掉自己的一切資源。但是如果還有其它的goroutine沒有退齣，他們可能沒辦法被正確地取消掉，也有可能被取消但是取消操作會很花時間；所以這裡的一箇調研還是很有必要的。我們用panic來穫取到足夠的信息來驗証我們上麫的判斷，看看最終到底是什麼樣的情況。
|
||
|
||
練習8.10: HTTP請求可能會因http.Request結構體中Cancel channel的關閉而取消。脩改8.6節中的web crawler來支持取消http請求。
|
||
|
||
提示: http.Get併沒有提供方便地定製一箇請求的方法。你可以用http.NewRequest來取而代之，設置它的Cancel字段，然後用http.DefaultClient.Do(req)來進行這箇http請求。
|
||
|
||
練習8.11:緊接着8.4.4中的mirroredQuery流程，實現一箇併發請求url的fetch的變種。噹第一箇請求返迴時，直接取消其它的請求。
|