搜尋
首頁後端開發GolangGoroutines 和 Channels:Go 中的並發模式

並發使我們能夠獨立處理多個任務。 Goroutine 是一種獨立處理多個任務的簡單方法。在這篇文章中,我們逐步增強了一個 http 處理程序,該程序接受文件,並利用通道和同步包探索 Go 中的各種並發模式。

設定

在進入並發模式之前,讓我們先做好準備。想像一下,我們有一個 HTTP 處理程序,它透過表單接受多個檔案並以某種方式處理這些檔案。

func processFile(file multipart.File) {
   // do something with the file
   fmt.Println("Processing file...")
   time.Sleep(100 * time.Millisecond) // Simulating file processing time
}
func UploadHandler(w http.ResponseWriter, r *http.Request) {
   // limit to 10mb 
   if err := r.ParseMultipartForm(10 



<p>在上面的範例中,我們從表單接收檔案並按順序處理它們。如果上傳 10 個文件,則需要 1 秒鐘才能完成該過程並向客戶端發送回應。 <br>
當處理許多文件時,這可能會成為瓶頸,但是透過 Go 的並發支持,我們可以輕鬆解決這個問題。 </p>
<h2>
  
  
  等待組
</h2>

<p>為了解決這個問題,我們可以並發處理文件。要產生一個新的 goroutine,我們可以在函數呼叫前加上 go 關鍵字,例如去處理檔案(f)。然而,由於 goroutine 是非阻塞的,處理程序可能會在進程完成之前返回,從而導致檔案可能未處理或返回不正確的狀態。要等待所有檔案的處理,我們可以使用sync.WaitGroup。 <br>
WaitGroup 等待多個 goroutine 完成,對於我們產生的每個 goroutine,我們也應該增加 WaitGroup 中的計數器,這可以透過 Add 函數來完成。當 goroutine 完成時,應該呼叫 Done,以便計數器減一。在從函數返回之前,應該呼叫 Wait,函數會阻塞,直到 WaitGroup 的計數器為 0。 <br>
</p>

<pre class="brush:php;toolbar:false">func UploadHandler(w http.ResponseWriter, r *http.Request) {
   if err := r.ParseMultipartForm(10 



<p>現在,對於每個上傳的文件,都會產生一個新的 goroutine,這可能會壓垮系統。一種解決方案是限制生成的 goroutine 的數量。 </p>

<h2>
  
  
  使用信號量限制並發
</h2>

<p>信號量只是一個變量,我們可以用它來控制多個線程(或在本例中為 goroutine)對公共資源的存取。 <br><br>
在 Go 中,我們可以利用緩衝通道來實現訊號量。 </p>
<h3>
  
  
  頻道
</h3>

<p>在進入實作之前,我們先來看看什麼是通道以及緩衝通道和非緩衝通道之間的差異。 </p>

<p>通道是一個管道,我們可以透過它發送和接收數據,以便在 go 例程之間安全地通訊。 <br>
通道必須使用 make 函數建立。 <br>
</p><pre class="brush:php;toolbar:false">
func processFile(file multipart.File) {
   // do something with the file
   fmt.Println("Processing file...")
   time.Sleep(100 * time.Millisecond) // Simulating file processing time
}
func UploadHandler(w http.ResponseWriter, r *http.Request) {
   // limit to 10mb 
   if err := r.ParseMultipartForm(10 



<p>通道有一個特殊的運算子
請操作員指向通道 ch <br>
<img src="/static/imghwm/default1.png" data-src="https://img.php.cn/upload/article/000/000/000/173404051364120.jpg?x-oss-process=image/resize,p_40" class="lazy" alt="Goroutines and Channels: Concurrency Patterns in Go"><br>
該動畫形像地展示了生產者透過無緩衝通道發送值 1 以及消費者從該通道讀取資料的情況。 </p>

<p>如果生產者發送事件的速度比消費者處理的速度快,那麼我們可以選擇利用<strong>緩衝通道</strong>來排隊多個訊息,而不會阻塞生產者,直到緩衝區已滿。同時,消費者可以按照自己的步調處理訊息。 <br>
</p>

<pre class="brush:php;toolbar:false">func UploadHandler(w http.ResponseWriter, r *http.Request) {
   if err := r.ParseMultipartForm(10 



<p>在此範例中,生產者最多可以發送兩個項目而不會阻塞。當緩衝區達到容量時,生產者將阻塞,直到消費者處理了至少一則訊息。 </p>

<p><img src="/static/imghwm/default1.png" data-src="https://img.php.cn/upload/article/000/000/000/173404051459967.jpg?x-oss-process=image/resize,p_40" class="lazy" alt="Goroutines and Channels: Concurrency Patterns in Go"></p>

<p>回到最初的問題,我們要限制同時處理文件的 goroutine 數量。為此,我們可以利用緩衝通道。 <br>
</p>

<pre class="brush:php;toolbar:false">ch := make(chan int)

在這個範例中,我們新增了一個容量為 5 的緩衝通道,這使我們能夠同時處理 5 個檔案並限制系統壓力。

但是如果並非所有檔案都相等怎麼辦?我們可以可靠地預測不同的文件類型或文件大小需要更多的資源來處理。在這種情況下,我們可以使用加權信號量。

加權信號量

簡單地說,使用加權訊號量,我們可以為單一任務分配更多資源。 Go 已經在擴展同步包中提供了加權信號量的實作。

ch := make(chan int, 2)

在此版本中,我們建立了一個具有5 個槽的加權訊號量,如果只上傳影像,例如進程會同時處理5 個影像,但是如果上傳PDF,則會取得2 個槽,這將減少可處理的文件量同時。

結論

我們探討了 Go 中的一些並發模​​式,利用sync.WaitGroup 和訊號量來控制並發任務的數量。然而,還有更多可用的工具,我們可以利用通道來建立工作池、新增逾時或使用扇入/扇出模式。
此外,錯誤處理是一個重要方面,但為了簡單起見,大多數情況下都忽略了這一點。
處理錯誤的一種方法是利用通道來聚合錯誤並在所有 goroutine 完成後處理它們。

Go 也提供了 errgroup.Group ,它與sync.WaitGroups 相關,但增加了對傳回錯誤的任務的處理。
該包可以在擴展同步包中找到。

以上是Goroutines 和 Channels:Go 中的並發模式的詳細內容。更多資訊請關注PHP中文網其他相關文章!

陳述
本文內容由網友自願投稿,版權歸原作者所有。本站不承擔相應的法律責任。如發現涉嫌抄襲或侵權的內容,請聯絡admin@php.cn
Go語言包導入:帶下劃線和不帶下劃線的區別是什麼?Go語言包導入:帶下劃線和不帶下劃線的區別是什麼?Mar 03, 2025 pm 05:17 PM

本文解釋了GO的軟件包導入機制:命名imports(例如導入“ fmt”)和空白導入(例如導入_ fmt; fmt;)。 命名導入使包裝內容可訪問,而空白導入僅執行t

Beego框架中NewFlash()函數如何實現頁面間短暫信息傳遞?Beego框架中NewFlash()函數如何實現頁面間短暫信息傳遞?Mar 03, 2025 pm 05:22 PM

本文解釋了Beego的NewFlash()函數,用於Web應用程序中的頁間數據傳輸。 它專注於使用newflash()在控制器之間顯示臨時消息(成功,錯誤,警告),並利用會話機制。 Lima

Go語言中如何將MySQL查詢結果List轉換為自定義結構體切片?Go語言中如何將MySQL查詢結果List轉換為自定義結構體切片?Mar 03, 2025 pm 05:18 PM

本文詳細介紹了MySQL查詢結果的有效轉換為GO結構切片。 它強調使用數據庫/SQL的掃描方法來最佳性能,避免手動解析。 使用DB標籤和Robus的結構現場映射的最佳實踐

如何編寫模擬對象和存根以進行測試?如何編寫模擬對象和存根以進行測試?Mar 10, 2025 pm 05:38 PM

本文演示了創建模擬和存根進行單元測試。 它強調使用接口,提供模擬實現的示例,並討論最佳實踐,例如保持模擬集中並使用斷言庫。 文章

如何定義GO中仿製藥的自定義類型約束?如何定義GO中仿製藥的自定義類型約束?Mar 10, 2025 pm 03:20 PM

本文探討了GO的仿製藥自定義類型約束。 它詳細介紹了界面如何定義通用功能的最低類型要求,從而改善了類型的安全性和代碼可重複使用性。 本文還討論了局限性和最佳實踐

Go語言如何便捷地寫入文件?Go語言如何便捷地寫入文件?Mar 03, 2025 pm 05:15 PM

本文詳細介紹了在GO中詳細介紹有效的文件,將OS.WriteFile(適用於小文件)與OS.openfile和緩衝寫入(最佳大型文件)進行比較。 它強調了使用延遲並檢查特定錯誤的可靠錯誤處理。

您如何在GO中編寫單元測試?您如何在GO中編寫單元測試?Mar 21, 2025 pm 06:34 PM

本文討論了GO中的編寫單元測試,涵蓋了最佳實踐,模擬技術和有效測試管理的工具。

如何使用跟踪工具了解GO應用程序的執行流?如何使用跟踪工具了解GO應用程序的執行流?Mar 10, 2025 pm 05:36 PM

本文使用跟踪工具探討了GO應用程序執行流。 它討論了手冊和自動儀器技術,比較諸如Jaeger,Zipkin和Opentelemetry之類的工具,並突出顯示有效的數據可視化

See all articles

熱AI工具

Undresser.AI Undress

Undresser.AI Undress

人工智慧驅動的應用程序,用於創建逼真的裸體照片

AI Clothes Remover

AI Clothes Remover

用於從照片中去除衣服的線上人工智慧工具。

Undress AI Tool

Undress AI Tool

免費脫衣圖片

Clothoff.io

Clothoff.io

AI脫衣器

AI Hentai Generator

AI Hentai Generator

免費產生 AI 無盡。

熱門文章

R.E.P.O.能量晶體解釋及其做什麼(黃色晶體)
2 週前By尊渡假赌尊渡假赌尊渡假赌
倉庫:如何復興隊友
4 週前By尊渡假赌尊渡假赌尊渡假赌
Hello Kitty Island冒險:如何獲得巨型種子
4 週前By尊渡假赌尊渡假赌尊渡假赌

熱工具

MantisBT

MantisBT

Mantis是一個易於部署的基於Web的缺陷追蹤工具,用於幫助產品缺陷追蹤。它需要PHP、MySQL和一個Web伺服器。請查看我們的演示和託管服務。

DVWA

DVWA

Damn Vulnerable Web App (DVWA) 是一個PHP/MySQL的Web應用程序,非常容易受到攻擊。它的主要目標是成為安全專業人員在合法環境中測試自己的技能和工具的輔助工具,幫助Web開發人員更好地理解保護網路應用程式的過程,並幫助教師/學生在課堂環境中教授/學習Web應用程式安全性。 DVWA的目標是透過簡單直接的介面練習一些最常見的Web漏洞,難度各不相同。請注意,該軟體中

SublimeText3 英文版

SublimeText3 英文版

推薦:為Win版本,支援程式碼提示!

SAP NetWeaver Server Adapter for Eclipse

SAP NetWeaver Server Adapter for Eclipse

將Eclipse與SAP NetWeaver應用伺服器整合。

Dreamweaver Mac版

Dreamweaver Mac版

視覺化網頁開發工具