mirror of
https://github.com/gopl-zh/gopl-zh.github.com.git
synced 2025-12-18 19:54:21 +08:00
rebuild
This commit is contained in:
chai2010
124
ch8/ch8-09.html
124
ch8/ch8-09.html
@@ -5,7 +5,7 @@
|
||||
|
||||
<meta charset="UTF-8">
|
||||
<meta http-equiv="X-UA-Compatible" content="IE=edge" />
|
||||
<title>併髮的退齣 | Go编程语言</title>
|
||||
<title>併發的退齣 | Go编程语言</title>
|
||||
<meta content="text/html; charset=utf-8" http-equiv="Content-Type">
|
||||
<meta name="description" content="">
|
||||
<meta name="generator" content="GitBook 2.5.2">
|
||||
@@ -48,7 +48,7 @@
|
||||
<body>
|
||||
|
||||
|
||||
<div class="book" data-level="8.9" data-chapter-title="併髮的退齣" data-filepath="ch8/ch8-09.md" data-basepath=".." data-revision="Wed Dec 16 2015 10:54:29 GMT+0800 (中国标准时间)">
|
||||
<div class="book" data-level="8.9" data-chapter-title="併發的退齣" data-filepath="ch8/ch8-09.md" data-basepath=".." data-revision="Mon Dec 21 2015 12:51:02 GMT+0800 (中国标准时间)">
|
||||
|
||||
|
||||
<div class="book-summary">
|
||||
@@ -146,7 +146,7 @@
|
||||
|
||||
<b>0.5.</b>
|
||||
|
||||
緻謝
|
||||
致謝
|
||||
</a>
|
||||
|
||||
|
||||
@@ -212,7 +212,7 @@
|
||||
|
||||
<b>1.3.</b>
|
||||
|
||||
査找重復的行
|
||||
査找重複的行
|
||||
</a>
|
||||
|
||||
|
||||
@@ -227,7 +227,7 @@
|
||||
|
||||
<b>1.4.</b>
|
||||
|
||||
GIF動畫
|
||||
GIF動畵
|
||||
</a>
|
||||
|
||||
|
||||
@@ -257,7 +257,7 @@
|
||||
|
||||
<b>1.6.</b>
|
||||
|
||||
併髮穫取多個URL
|
||||
併發穫取多個URL
|
||||
</a>
|
||||
|
||||
|
||||
@@ -479,7 +479,7 @@
|
||||
|
||||
<b>3.3.</b>
|
||||
|
||||
復數
|
||||
複數
|
||||
</a>
|
||||
|
||||
|
||||
@@ -494,7 +494,7 @@
|
||||
|
||||
<b>3.4.</b>
|
||||
|
||||
佈爾型
|
||||
布爾型
|
||||
</a>
|
||||
|
||||
|
||||
@@ -544,7 +544,7 @@
|
||||
|
||||
<b>4.</b>
|
||||
|
||||
復閤數據類型
|
||||
複合數據類型
|
||||
</a>
|
||||
|
||||
|
||||
@@ -857,7 +857,7 @@
|
||||
|
||||
<b>6.2.</b>
|
||||
|
||||
基於指鍼對象的方法
|
||||
基於指針對象的方法
|
||||
</a>
|
||||
|
||||
|
||||
@@ -887,7 +887,7 @@
|
||||
|
||||
<b>6.4.</b>
|
||||
|
||||
方法值和方法錶達式
|
||||
方法值和方法表達式
|
||||
</a>
|
||||
|
||||
|
||||
@@ -953,7 +953,7 @@
|
||||
|
||||
<b>7.1.</b>
|
||||
|
||||
接口是閤約
|
||||
接口是合約
|
||||
</a>
|
||||
|
||||
|
||||
@@ -1073,7 +1073,7 @@
|
||||
|
||||
<b>7.9.</b>
|
||||
|
||||
示例: 錶達式求值
|
||||
示例: 表達式求值
|
||||
</a>
|
||||
|
||||
|
||||
@@ -1103,7 +1103,7 @@
|
||||
|
||||
<b>7.11.</b>
|
||||
|
||||
基於類型斷言識彆錯誤類型
|
||||
基於類型斷言識别錯誤類型
|
||||
</a>
|
||||
|
||||
|
||||
@@ -1214,7 +1214,7 @@
|
||||
|
||||
<b>8.2.</b>
|
||||
|
||||
示例: 併髮的Clock服務
|
||||
示例: 併發的Clock服務
|
||||
</a>
|
||||
|
||||
|
||||
@@ -1229,7 +1229,7 @@
|
||||
|
||||
<b>8.3.</b>
|
||||
|
||||
示例: 併髮的Echo服務
|
||||
示例: 併發的Echo服務
|
||||
</a>
|
||||
|
||||
|
||||
@@ -1274,7 +1274,7 @@
|
||||
|
||||
<b>8.6.</b>
|
||||
|
||||
示例: 併髮的Web爬蟲
|
||||
示例: 併發的Web爬蟲
|
||||
</a>
|
||||
|
||||
|
||||
@@ -1289,7 +1289,7 @@
|
||||
|
||||
<b>8.7.</b>
|
||||
|
||||
基於select的多路復用
|
||||
基於select的多路複用
|
||||
</a>
|
||||
|
||||
|
||||
@@ -1304,7 +1304,7 @@
|
||||
|
||||
<b>8.8.</b>
|
||||
|
||||
示例: 併髮的字典遍歷
|
||||
示例: 併發的字典遍歷
|
||||
</a>
|
||||
|
||||
|
||||
@@ -1319,7 +1319,7 @@
|
||||
|
||||
<b>8.9.</b>
|
||||
|
||||
併髮的退齣
|
||||
併發的退齣
|
||||
</a>
|
||||
|
||||
|
||||
@@ -1354,7 +1354,7 @@
|
||||
|
||||
<b>9.</b>
|
||||
|
||||
基於共享變量的併髮
|
||||
基於共享變量的併發
|
||||
</a>
|
||||
|
||||
|
||||
@@ -1415,7 +1415,7 @@
|
||||
|
||||
<b>9.4.</b>
|
||||
|
||||
內存衕步
|
||||
內存同步
|
||||
</a>
|
||||
|
||||
|
||||
@@ -1460,7 +1460,7 @@
|
||||
|
||||
<b>9.7.</b>
|
||||
|
||||
示例: 併髮的非阻塞緩存
|
||||
示例: 併發的非阻塞緩存
|
||||
</a>
|
||||
|
||||
|
||||
@@ -1475,7 +1475,7 @@
|
||||
|
||||
<b>9.8.</b>
|
||||
|
||||
Goroutines和綫程
|
||||
Goroutines和線程
|
||||
</a>
|
||||
|
||||
|
||||
@@ -1748,7 +1748,7 @@
|
||||
|
||||
<b>12.1.</b>
|
||||
|
||||
為何需要反射?
|
||||
爲何需要反射?
|
||||
</a>
|
||||
|
||||
|
||||
@@ -1793,7 +1793,7 @@
|
||||
|
||||
<b>12.4.</b>
|
||||
|
||||
示例: 編碼S錶達式
|
||||
示例: 編碼S表達式
|
||||
</a>
|
||||
|
||||
|
||||
@@ -1823,7 +1823,7 @@
|
||||
|
||||
<b>12.6.</b>
|
||||
|
||||
示例: 解碼S錶達式
|
||||
示例: 解碼S表達式
|
||||
</a>
|
||||
|
||||
|
||||
@@ -1975,50 +1975,14 @@
|
||||
|
||||
</li>
|
||||
|
||||
<li class="chapter " data-level="14" data-path="exercise/ex.html">
|
||||
|
||||
|
||||
<a href="../exercise/ex.html">
|
||||
|
||||
<i class="fa fa-check"></i>
|
||||
|
||||
<b>14.</b>
|
||||
|
||||
習題解答
|
||||
</a>
|
||||
|
||||
|
||||
<ul class="articles">
|
||||
|
||||
|
||||
<li class="chapter " data-level="14.1" data-path="exercise/ex-ch1.html">
|
||||
|
||||
|
||||
<a href="../exercise/ex-ch1.html">
|
||||
|
||||
<i class="fa fa-check"></i>
|
||||
|
||||
<b>14.1.</b>
|
||||
|
||||
第一章 入門
|
||||
</a>
|
||||
|
||||
|
||||
</li>
|
||||
|
||||
|
||||
</ul>
|
||||
|
||||
</li>
|
||||
|
||||
<li class="chapter " data-level="15" data-path="errata.html">
|
||||
<li class="chapter " data-level="14" data-path="errata.html">
|
||||
|
||||
|
||||
<a href="../errata.html">
|
||||
|
||||
<i class="fa fa-check"></i>
|
||||
|
||||
<b>15.</b>
|
||||
<b>14.</b>
|
||||
|
||||
勘誤
|
||||
</a>
|
||||
@@ -2059,12 +2023,12 @@
|
||||
|
||||
<section class="normal" id="section-">
|
||||
|
||||
<h2 id="89-併髮的退齣">8.9. 併髮的退齣</h2>
|
||||
<p>有時候我們需要通知goroutine停止它正在乾的事情，比如一箇正在執行計算的web服務，然而它的客戶端已經斷開了和服務端的連接。</p>
|
||||
<p>Go語言併沒有提供在一箇goroutine中終止另一箇goroutine的方法，由於這樣會導緻goroutine之間的共享變量落在未定義的狀態上。在8.7節中的rocket launch程序中，我們往名字叫abort的channel裡發送了一箇簡單的值，在countdown的goroutine中會把這箇值理解爲自己的退齣信號。但是如果我們想要退齣兩箇或者任意多箇goroutine怎麼辦呢？</p>
|
||||
<p>一種可能的手段是嚮abort的channel裡發送和goroutine數目一樣多的事件來退齣它們。如果這些goroutine中已經有一些自己退齣了，那麼會導緻我們的channel裡的事件數比goroutine還多，這樣導緻我們的發送直接被阻塞。另一方麫，如果這些goroutine又生成了其它的goroutine，我們的channel裡的數目又太少了，所以有些goroutine可能會無法接收到退齣消息。一般情況下我們是很難知道在某一箇時刻具體有多少箇goroutine在運行着的。另外，噹一箇goroutine從abort channel中接收到一箇值的時候，他會消費掉這箇值，這樣其它的goroutine就沒法看到這條信息。爲了能夠達到我們退齣goroutine的目的，我們需要更靠譜的策略，來通過一箇channel把消息廣播齣去，這樣goroutine們能夠看到這條事件消息，併且在事件完成之後，可以知道這件事已經發生過了。</p>
|
||||
<p>迴憶一下我們關閉了一箇channel併且被消費掉了所有已發送的值，操作channel之後的代碼可以立卽被執行，併且會產生零值。我們可以將這箇機製擴展一下，來作爲我們的廣播機製：不要嚮channel發送值，而是用關閉一箇channel來進行廣播。</p>
|
||||
<p>隻要一些小脩改，我們就可以把退齣邏輯加入到前一節的du程序。首先，我們創建一箇退齣的channel，這箇channel不會嚮其中發送任何值，但其所在的閉包內要寫明程序需要退齣。我們衕時還定義了一箇工具函數，cancelled，這箇函數在被調用的時候會輪詢退齣狀態。</p>
|
||||
<h2 id="89-併發的退齣">8.9. 併發的退齣</h2>
|
||||
<p>有時候我們需要通知goroutine停止它正在榦的事情，比如一個正在執行計算的web服務，然而它的客戶端已經斷開了和服務端的連接。</p>
|
||||
<p>Go語言併沒有提供在一個goroutine中終止另一個goroutine的方法，由於這樣會導致goroutine之間的共享變量落在未定義的狀態上。在8.7節中的rocket launch程序中，我們往名字叫abort的channel里發送了一個簡單的值，在countdown的goroutine中會把這個值理解爲自己的退齣信號。但是如果我們想要退齣兩個或者任意多個goroutine怎麽辦呢？</p>
|
||||
<p>一種可能的手段是向abort的channel里發送和goroutine數目一樣多的事件來退齣它們。如果這些goroutine中已經有一些自己退齣了，那麽會導致我們的channel里的事件數比goroutine還多，這樣導致我們的發送直接被阻塞。另一方面，如果這些goroutine又生成了其它的goroutine，我們的channel里的數目又太少了，所以有些goroutine可能會無法接收到退齣消息。一般情況下我們是很難知道在某一個時刻具體有多少個goroutine在運行着的。另外，當一個goroutine從abort channel中接收到一個值的時候，他會消費掉這個值，這樣其它的goroutine就沒法看到這條信息。爲了能夠達到我們退齣goroutine的目的，我們需要更靠譜的策略，來通過一個channel把消息廣播齣去，這樣goroutine們能夠看到這條事件消息，併且在事件完成之後，可以知道這件事已經發生過了。</p>
|
||||
<p>迴憶一下我們關閉了一個channel併且被消費掉了所有已發送的值，操作channel之後的代碼可以立卽被執行，併且會産生零值。我們可以將這個機製擴展一下，來作爲我們的廣播機製：不要向channel發送值，而是用關閉一個channel來進行廣播。</p>
|
||||
<p>隻要一些小脩改，我們就可以把退齣邏輯加入到前一節的du程序。首先，我們創建一個退齣的channel，這個channel不會向其中發送任何值，但其所在的閉包內要寫明程序需要退齣。我們同時還定義了一個工具函數，cancelled，這個函數在被調用的時候會輪詢退齣狀態。</p>
|
||||
<pre><code class="lang-go">gopl.io/ch8/du4
|
||||
<span class="hljs-keyword">var</span> done = <span class="hljs-built_in">make</span>(<span class="hljs-keyword">chan</span> <span class="hljs-keyword">struct</span>{})
|
||||
|
||||
@@ -2077,14 +2041,14 @@
|
||||
}
|
||||
}
|
||||
</code></pre>
|
||||
<p>下麫我們創建一箇從標準輸入流中讀取內容的goroutine，這是一箇比較典型的連接到終端的程序。每噹有輸入被讀到(比如用戶按了迴車鍵)，這箇goroutine就會把取消消息通過關閉done的channel廣播齣去。</p>
|
||||
<p>下面我們創建一個從標準輸入流中讀取內容的goroutine，這是一個比較典型的連接到終端的程序。每當有輸入被讀到(比如用戶按了迴車鍵)，這個goroutine就會把取消消息通過關閉done的channel廣播齣去。</p>
|
||||
<pre><code class="lang-go"><span class="hljs-comment">// Cancel traversal when input is detected.</span>
|
||||
<span class="hljs-keyword">go</span> <span class="hljs-keyword">func</span>() {
|
||||
os.Stdin.Read(<span class="hljs-built_in">make</span>([]<span class="hljs-typename">byte</span>, <span class="hljs-number">1</span>)) <span class="hljs-comment">// read a single byte</span>
|
||||
<span class="hljs-built_in">close</span>(done)
|
||||
}()
|
||||
</code></pre>
|
||||
<p>現在我們需要使我們的goroutine來對取消進行響應。在main goroutine中，我們添加了select的第三箇case語句，嘗試從done channel中接收內容。如果這箇case被滿足的話，在select到的時候卽會返迴，但在結束之前我們需要把fileSizes channel中的內容“排”空，在channel被關閉之前，捨棄掉所有值。這樣可以保証對walkDir的調用不要被嚮fileSizes發送信息阻塞住，可以正確地完成。</p>
|
||||
<p>現在我們需要使我們的goroutine來對取消進行響應。在main goroutine中，我們添加了select的第三個case語句，嚐試從done channel中接收內容。如果這個case被滿足的話，在select到的時候卽會返迴，但在結束之前我們需要把fileSizes channel中的內容“排”空，在channel被關閉之前，舍棄掉所有值。這樣可以保證對walkDir的調用不要被向fileSizes發送信息阻塞住，可以正確地完成。</p>
|
||||
<pre><code class="lang-go"><span class="hljs-keyword">for</span> {
|
||||
<span class="hljs-keyword">select</span> {
|
||||
<span class="hljs-keyword">case</span> <-done:
|
||||
@@ -2098,7 +2062,7 @@
|
||||
}
|
||||
}
|
||||
</code></pre>
|
||||
<p>walkDir這箇goroutine一啟動就會輪詢取消狀態，如果取消狀態被設置的話會直接返迴，併且不做額外的事情。這樣我們將所有在取消事件之後創建的goroutine改變爲無操作。</p>
|
||||
<p>walkDir這個goroutine一啟動就會輪詢取消狀態，如果取消狀態被設置的話會直接返迴，併且不做額外的事情。這樣我們將所有在取消事件之後創建的goroutine改變爲無操作。</p>
|
||||
<pre><code class="lang-go"><span class="hljs-keyword">func</span> walkDir(dir <span class="hljs-typename">string</span>, n *sync.WaitGroup, fileSizes <span class="hljs-keyword">chan</span><- <span class="hljs-typename">int64</span>) {
|
||||
<span class="hljs-keyword">defer</span> n.Done()
|
||||
<span class="hljs-keyword">if</span> cancelled() {
|
||||
@@ -2109,8 +2073,8 @@
|
||||
}
|
||||
}
|
||||
</code></pre>
|
||||
<p>在walkDir函數的循環中我們對取消狀態進行輪詢可以帶來明顯的益處，可以避免在取消事件發生時還去創建goroutine。取消本身是有一些代價的；想要快速的響應需要對程序邏輯進行侵入式的脩改。確保在取消發生之後不要有代價太大的操作可能會需要脩改你代碼裡的很多地方，但是在一些重要的地方去檢査取消事件也確實能帶來很大的好處。</p>
|
||||
<p>對這箇程序的一箇簡單的性能分析可以揭示瓶頸在dirents函數中穫取一箇信號量。下麫的select可以讓這種操作可以被取消，併且可以將取消時的延遲從幾百毫秒降低到幾十毫秒。</p>
|
||||
<p>在walkDir函數的循環中我們對取消狀態進行輪詢可以帶來明顯的益處，可以避免在取消事件發生時還去創建goroutine。取消本身是有一些代價的；想要快速的響應需要對程序邏輯進行侵入式的脩改。確保在取消發生之後不要有代價太大的操作可能會需要脩改你代碼里的很多地方，但是在一些重要的地方去檢査取消事件也確實能帶來很大的好處。</p>
|
||||
<p>對這個程序的一個簡單的性能分析可以揭示瓶頸在dirents函數中穫取一個信號量。下面的select可以讓這種操作可以被取消，併且可以將取消時的延遲從幾百毫秒降低到幾十毫秒。</p>
|
||||
<pre><code class="lang-go"><span class="hljs-keyword">func</span> dirents(dir <span class="hljs-typename">string</span>) []os.FileInfo {
|
||||
<span class="hljs-keyword">select</span> {
|
||||
<span class="hljs-keyword">case</span> sema <- <span class="hljs-keyword">struct</span>{}{}: <span class="hljs-comment">// acquire token</span>
|
||||
@@ -2121,10 +2085,10 @@
|
||||
<span class="hljs-comment">// ...read directory...</span>
|
||||
}
|
||||
</code></pre>
|
||||
<p>現在噹取消發生時，所有後檯的goroutine都會迅速停止併且主函數會返迴。噹然，噹主函數返迴時，一箇程序會退齣，而我們又無法在主函數退齣的時候確認其已經釋放了所有的資源(譯註：因爲程序都退齣了，你的代碼都沒法執行了)。這裡有一箇方便的竅門我們可以一用：取代掉直接從主函數返迴，我們調用一箇panic，然後runtime會把每一箇goroutine的棧dump下來。如果main goroutine是唯一一箇剩下的goroutine的話，他會清理掉自己的一切資源。但是如果還有其它的goroutine沒有退齣，他們可能沒辦法被正確地取消掉，也有可能被取消但是取消操作會很花時間；所以這裡的一箇調研還是很有必要的。我們用panic來穫取到足夠的信息來驗証我們上麫的判斷，看看最終到底是什麼樣的情況。</p>
|
||||
<p>現在當取消發生時，所有後颱的goroutine都會迅速停止併且主函數會返迴。當然，當主函數返迴時，一個程序會退齣，而我們又無法在主函數退齣的時候確認其已經釋放了所有的資源(譯註：因爲程序都退齣了，你的代碼都沒法執行了)。這里有一個方便的竅門我們可以一用：取代掉直接從主函數返迴，我們調用一個panic，然後runtime會把每一個goroutine的棧dump下來。如果main goroutine是唯一一個剩下的goroutine的話，他會清理掉自己的一切資源。但是如果還有其它的goroutine沒有退齣，他們可能沒辦法被正確地取消掉，也有可能被取消但是取消操作會很花時間；所以這里的一個調研還是很有必要的。我們用panic來穫取到足夠的信息來驗證我們上面的判斷，看看最終到底是什麽樣的情況。</p>
|
||||
<p>練習8.10: HTTP請求可能會因http.Request結構體中Cancel channel的關閉而取消。脩改8.6節中的web crawler來支持取消http請求。</p>
|
||||
<p>提示: http.Get併沒有提供方便地定製一箇請求的方法。你可以用http.NewRequest來取而代之，設置它的Cancel字段，然後用http.DefaultClient.Do(req)來進行這箇http請求。</p>
|
||||
<p>練習8.11:緊接着8.4.4中的mirroredQuery流程，實現一箇併發請求url的fetch的變種。噹第一箇請求返迴時，直接取消其它的請求。</p>
|
||||
<p>提示: http.Get併沒有提供方便地定製一個請求的方法。你可以用http.NewRequest來取而代之，設置它的Cancel字段，然後用http.DefaultClient.Do(req)來進行這個http請求。</p>
|
||||
<p>練習8.11:緊接着8.4.4中的mirroredQuery流程，實現一個併發請求url的fetch的變種。當第一個請求返迴時，直接取消其它的請求。</p>
|
||||
|
||||
|
||||
</section>
|
||||
@@ -2135,7 +2099,7 @@
|
||||
</div>
|
||||
|
||||
|
||||
<a href="../ch8/ch8-08.html" class="navigation navigation-prev " aria-label="Previous page: 示例: 併髮的字典遍歷"><i class="fa fa-angle-left"></i></a>
|
||||
<a href="../ch8/ch8-08.html" class="navigation navigation-prev " aria-label="Previous page: 示例: 併發的字典遍歷"><i class="fa fa-angle-left"></i></a>
|
||||
|
||||
|
||||
<a href="../ch8/ch8-10.html" class="navigation navigation-next " aria-label="Next page: 示例: 聊天服務"><i class="fa fa-angle-right"></i></a>
|
||||
|
||||
Reference in New Issue
Block a user