搜尋
首頁後端開發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
Golang和Python:了解差異Golang和Python:了解差異Apr 18, 2025 am 12:21 AM

Golang和Python的主要區別在於並發模型、類型系統、性能和執行速度。 1.Golang使用CSP模型,適用於高並發任務;Python依賴多線程和GIL,適合I/O密集型任務。 2.Golang是靜態類型,Python是動態類型。 3.Golang編譯型語言執行速度快,Python解釋型語言開發速度快。

Golang vs.C:評估速度差Golang vs.C:評估速度差Apr 18, 2025 am 12:20 AM

Golang通常比C 慢,但Golang在並發編程和開發效率上更具優勢:1)Golang的垃圾回收和並發模型使其在高並發場景下表現出色;2)C 通過手動內存管理和硬件優化獲得更高性能,但開發複雜度較高。

Golang:雲計算和DevOps的關鍵語言Golang:雲計算和DevOps的關鍵語言Apr 18, 2025 am 12:18 AM

Golang在雲計算和DevOps中的應用廣泛,其優勢在於簡單性、高效性和並發編程能力。 1)在雲計算中,Golang通過goroutine和channel機制高效處理並發請求。 2)在DevOps中,Golang的快速編譯和跨平台特性使其成為自動化工具的首選。

Golang和C:了解執行效率Golang和C:了解執行效率Apr 18, 2025 am 12:16 AM

Golang和C 在執行效率上的表現各有優勢。 1)Golang通過goroutine和垃圾回收提高效率,但可能引入暫停時間。 2)C 通過手動內存管理和優化實現高性能,但開發者需處理內存洩漏等問題。選擇時需考慮項目需求和團隊技術棧。

Golang vs. Python:並發和多線程Golang vs. Python:並發和多線程Apr 17, 2025 am 12:20 AM

Golang更適合高並發任務,而Python在靈活性上更有優勢。 1.Golang通過goroutine和channel高效處理並發。 2.Python依賴threading和asyncio,受GIL影響,但提供多種並發方式。選擇應基於具體需求。

Golang和C:性能的權衡Golang和C:性能的權衡Apr 17, 2025 am 12:18 AM

Golang和C 在性能上的差異主要體現在內存管理、編譯優化和運行時效率等方面。 1)Golang的垃圾回收機制方便但可能影響性能,2)C 的手動內存管理和編譯器優化在遞歸計算中表現更為高效。

Golang vs. Python:申請和用例Golang vs. Python:申請和用例Apr 17, 2025 am 12:17 AM

selectgolangforhighpperformanceandcorrency,ifealforBackendServicesSandNetwork程序; selectpypypythonforrapiddevelopment,dataScience和machinelearningDuetoitsverserverserverserversator versator anderticality andextility andextentensivelibraries。

Golang vs. Python:主要差異和相似之處Golang vs. Python:主要差異和相似之處Apr 17, 2025 am 12:15 AM

Golang和Python各有优势:Golang适合高性能和并发编程,Python适用于数据科学和Web开发。Golang以其并发模型和高效性能著称,Python则以简洁语法和丰富库生态系统著称。

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.能量晶體解釋及其做什麼(黃色晶體)
1 個月前By尊渡假赌尊渡假赌尊渡假赌
R.E.P.O.最佳圖形設置
1 個月前By尊渡假赌尊渡假赌尊渡假赌
威爾R.E.P.O.有交叉遊戲嗎?
1 個月前By尊渡假赌尊渡假赌尊渡假赌

熱工具

VSCode Windows 64位元 下載

VSCode Windows 64位元 下載

微軟推出的免費、功能強大的一款IDE編輯器

MantisBT

MantisBT

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

ZendStudio 13.5.1 Mac

ZendStudio 13.5.1 Mac

強大的PHP整合開發環境

Dreamweaver Mac版

Dreamweaver Mac版

視覺化網頁開發工具

MinGW - Minimalist GNU for Windows

MinGW - Minimalist GNU for Windows

這個專案正在遷移到osdn.net/projects/mingw的過程中,你可以繼續在那裡關注我們。 MinGW:GNU編譯器集合(GCC)的本機Windows移植版本,可自由分發的導入函式庫和用於建置本機Windows應用程式的頭檔;包括對MSVC執行時間的擴展,以支援C99功能。 MinGW的所有軟體都可以在64位元Windows平台上運作。