go goroutine chan 用法

方法1

代碼

package mainimport ("fmt""sync""time"
)func main() {allChan := make(chan interface{}, 3)var sendWg, recvWg sync.WaitGroup // 分別同步發送和接收// 發送goroutinesendWg.Add(1)go func() {defer sendWg.Done()for i := 0; i < 10; i++ {time.Sleep(time.Millisecond * 10)allChan <- ifmt.Printf("發送: %d\n", i)}close(allChan) // 發送完成后關閉channel}()// 接收goroutinerecvWg.Add(1)go func() {defer recvWg.Done()for item := range allChan {time.Sleep(time.Millisecond * 20) // 模擬處理耗時fmt.Printf("接收: %v\n", item)}}()// 先等待發送完成,再等待接收完成sendWg.Wait()recvWg.Wait()fmt.Println("所有操作完成")
}

運行結果:

標準輸出:發送: 0
發送: 1
接收: 0
發送: 2
發送: 3
接收: 1
發送: 4
發送: 5
接收: 2
發送: 6
接收: 3
發送: 7
接收: 4
發送: 8
接收: 5
發送: 9
接收: 6
接收: 7
接收: 8
接收: 9
所有操作完成

分析

優化說明

  1. 雙重同步:
  • 使用兩個WaitGroup(sendWg和recvWg),分別等待發送和接收 goroutine 完成。
  • 先通過sendWg.Wait()確保所有數據發送完畢并關閉 channel;
  • 再通過recvWg.Wait()確保接收 goroutine 處理完所有數據。
  1. channel 關閉邏輯:
  • 發送完成后關閉 channel 是關鍵,這會讓接收 goroutine 的range循環在取完數據后自動退出,避免接收端阻塞。
  1. 適用場景:
  • 這種 “發送 + 接收都異步” 的模式適合需要主程序同時處理其他邏輯的場景(例如同時監控多個任務),但必須做好同步,否則會出現數據丟失。

方法2

代碼

package mainimport ("fmt""time"
)func main() {// 1. 數據通道:傳遞實際數據dataChan := make(chan interface{}, 3)// 2. 發送完成信號通道:發送方結束后通知sendDone := make(chan struct{})// 3. 接收完成信號通道:接收方結束后通知recvDone := make(chan struct{})// 發送goroutinego func() {for i := 0; i < 10; i++ {time.Sleep(time.Millisecond * 10)dataChan <- ifmt.Printf("發送: %d\n", i)}close(dataChan)       // 發送完畢,關閉數據通道(通知接收方結束)sendDone <- struct{}{} // 發送完成信號}()// 接收goroutinego func() {for item := range dataChan { // 當dataChan關閉且數據取完后,循環自動退出time.Sleep(time.Millisecond * 20)fmt.Printf("接收: %v\n", item)}recvDone <- struct{}{} // 接收完成信號}()// 主程序等待:先等發送完成,再等接收完成<-sendDone  // 阻塞等待發送完成<-recvDone  // 阻塞等待接收完成fmt.Println("所有操作完成")
}

運行結果

標準輸出:發送: 0
發送: 1
接收: 0
發送: 2
發送: 3
接收: 1
發送: 4
發送: 5
接收: 2
發送: 6
接收: 3
發送: 7
接收: 4
發送: 8
接收: 5
發送: 9
接收: 6
接收: 7
接收: 8
接收: 9
所有操作完成

那種更好呢

一、效率對比

sync.WaitGroup 略占優勢

  1. sync.WaitGroup 是 Go 標準庫專門為 “等待一組 goroutine 完成” 設計的同步原語,底層通過原子操作(計數器加減)實現,幾乎沒有額外開銷,執行效率極高。
  2. 它的邏輯簡單:Add 增加計數、Done 減少計數、Wait 阻塞直到計數歸零,整個過程不涉及復雜的 runtime 調度交互。
    多通道同步的開銷稍高
  3. 通道同步依賴于 channel 的發送 / 接收操作,這些操作需要與 Go runtime 的調度器交互(如檢查通道狀態、喚醒阻塞的 goroutine 等),理論上比原子操作多一些微小的開銷。
  4. 額外的信號通道(如 sendDone、recvDone)會占用少量內存(每個通道需要維護內部數據結構),但在實際應用中影響可忽略。

二、實用性與適用場景

sync.WaitGroup 更適合大多數場景

  1. 代碼簡潔:對于 “等待多個 goroutine 完成” 的場景,WaitGroup 的語義更直觀(Add/Done/Wait 直接對應 “注冊 - 完成 - 等待” 邏輯),可讀性更高。
  2. 擴展性好:如果需要等待多個發送者或接收者(如 10 個發送 goroutine),WaitGroup 只需一次 Add(10) 即可,無需額外定義多個信號通道。
  3. 通用性強:是 Go 社區的 “標準做法”,團隊協作時更容易被理解。
    多通道同步適合特定場景
  4. 符合 Go 哲學:更貼合 “用通信實現共享內存” 的 Go 設計思想,通過 channel 傳遞信號比直接操作計數器更 “Go 式”。
  5. 靈活擴展:如果需要更復雜的同步邏輯(如 “先等待 A 完成,再啟動 B,最后等待 B 完成”),通道的阻塞特性可以天然實現流程控制,而 WaitGroup 可能需要配合額外邏輯。
  6. 無依賴:不依賴 sync 包,純靠語言原生特性實現,適合理解 channel 機制的場景。

三、總結建議

優先選 sync.WaitGroup:在大多數業務代碼中,它更簡潔、高效、易維護,是同步 goroutine 的 “標準答案”。
選多通道同步:當你需要強調 “通信優先” 的設計,或同步邏輯較復雜(需要通過通道傳遞更多狀態)時,它是更優雅的選擇。

本質區別:

WaitGroup 是 “共享狀態” 式同步(通過計數器),多通道是 “通信” 式同步(通過信號傳遞)。兩者效率差異微小,選擇時主要看代碼可讀性和場景適配性。

本文來自互聯網用戶投稿,該文觀點僅代表作者本人,不代表本站立場。本站僅提供信息存儲空間服務,不擁有所有權,不承擔相關法律責任。
如若轉載,請注明出處:http://www.pswp.cn/bicheng/91997.shtml
繁體地址,請注明出處:http://hk.pswp.cn/bicheng/91997.shtml
英文地址,請注明出處:http://en.pswp.cn/bicheng/91997.shtml

如若內容造成侵權/違法違規/事實不符,請聯系多彩編程網進行投訴反饋email:809451989@qq.com,一經查實,立即刪除!

相關文章

Web前端文件上傳安全與敏感數據安全處理

一、文件上傳安全1. 文件上傳時的核心安全檢查點文件上傳是 Web 應用的高風險功能&#xff0c;需從多維度驗證&#xff0c;防止惡意文件上傳&#xff08;如木馬、病毒&#xff09;或路徑攻擊&#xff0c;關鍵檢查點包括&#xff1a;MIME 類型驗證檢查請求頭中的 Content-Type&a…

文法中的間接左遞歸

&#x1f31f; 第一步&#xff1a;理解基本概念? 什么是文法&#xff08;Grammar&#xff09;&#xff1f;在編程語言或語法分析中&#xff0c;文法 是一組規則&#xff0c;用來描述一種語言的結構。例如&#xff1a;S → A a A → B b B → S c 這表示&#xff1a;S 可以…

Anthropic:跨越生產效能拐點的AI增長飛輪

資本競賽中的戰略轉折點 人工智能領域的競爭已經從理念之爭演變為資本、算力與地緣政治影響力的全面較量。Anthropic傳聞中的1700億美元估值&#xff0c;如果成為現實&#xff0c;將標志著前沿AI發展格局的地震式轉變。這不僅僅是構建更智能模型的問題&#xff0c;更是為主導下…

【Unity3D實例-功能-移動】小兵移動-通過鼠標點擊進行

在Unity的世界里&#xff0c;當你輕點鼠標&#xff0c;角色仿佛被賦予了新的使命&#xff0c;沿著一條無形的軌跡&#xff0c;向著地圖上的目標點進發。每一次移動&#xff0c;不僅是簡單的位移&#xff0c;更是對未知的探索。這種交互&#xff0c;讓玩家與游戲世界緊密相連&am…

從0到1學PHP(十四):PHP 性能優化:打造高效應用

目錄一、PHP 性能評估與分析1.1 性能指標體系1.2 性能分析工具使用1.3 性能瓶頸定位方法與流程二、代碼層面優化技巧2.1 高效的循環與條件判斷寫法2.2 函數與類的優化設計2.3 內存管理與垃圾回收機制優化三、緩存策略與實現3.1 數據緩存3.2 頁面緩存與部分緩存技術3.3 OPcache …

移動管家手機控車系統硬件安裝與軟件綁定設置

移動管家手機控車系統硬件安裝與軟件綁定配合使用&#xff0c;具體設置步驟如下&#xff1a;一、硬件安裝準備 ?加裝智能控制主機?&#xff1a;需在車輛上加裝移動管家專用智能控制模塊&#xff0c;該模塊需與原車電路系統連接&#xff0c;并將原車鑰匙芯片焊接至主控盒內以實…

51單片機入門:數碼管原理介紹及C代碼實現

本文是江協科技up的課堂筆記&#xff01;大家可以去bilibili配合這位up的51單片機入門教程食用&#xff0c;效果更佳~我這里進行詳細介紹&#xff0c;希望你忘記數碼管的時候來這里看看&#xff01;&#xff08;你猜我為什么寫這個TAT&#xff09;一.基本介紹LED數碼管&#xf…

Apache Camel 簡介

相關文檔地址 https://camel.apache.org/components/next/index.htmlhttps://camel.apache.org/components/4.10.x/languages/simple-language.htmlhttps://camel.apache.org/manual/exception-clause.htmlhttps://camel.apache.org/manual/index.htmlhttps://camel.apache.org…

IP離線庫 輸入IP地址立即返回IP所在地址信息(支持Java、Python)

描述 本文實現&#xff1a; 1、離線查詢IP地址 2、IP地址精確到區域 3、IP地址支持國外IP 此時需要一個創建&#xff0c;比如我輸入一個8.8.8.8的IP立馬就需要返回給我一個中文地址信息&#xff0c; 類似于百度的IP搜索&#xff1a; 113.111.186.123如果現在離線環境或者在…

解決MySQL刪除/var/lib/mysql下的所有文件后無法啟動的問題

刪除 MySQL 數據目錄 /var/lib/mysql 下的所有文件后&#xff0c;MySQL 將無法啟動&#xff0c;因為該目錄包含了數據庫的所有數據文件、配置文件和系統表。當這些文件被刪除時&#xff0c;MySQL 無法找到必要的數據和配置&#xff0c;從而無法正常啟動。本文將詳細介紹解決這個…

蒼穹外賣項目學習——day1(項目概述、環境搭建)

文章目錄一、軟件開發整體介紹1.1 軟件開發流程1.2 角色分工1.3 軟件環境分類二、蒼穹外賣項目介紹2.1 定位2.2 功能架構2.3 技術選型三、開發環境搭建3.1 前端環境3.2 后端環境3.3 前后端聯調3.4 登錄功能優化四、接口文檔管理4.1 YApi4.2 Swagger (Knife4j)一、軟件開發整體介…

【QT】Qt信號與槽機制詳解信號和槽的本質自定義信號和槽帶參數的信號和槽

文章目錄前言一、信號的本質二、槽的本質三、 信號和槽的使?3.1 連接信號和槽四、使用步驟4.1 通過QtCreator?成信號槽代碼五、 ?定義信號和槽5.1 ?例1&#xff1a;信號和槽函數初步使用5.2 ?例2 兩個類使用5.3 示例3 按鈕使用觸發信號六、 帶參數的信號和槽6.1 ?例1&…

【OD機試題解法筆記】文件緩存系統

題目描述 請設計一個文件緩存系統&#xff0c;該文件緩存系統可以指定緩存的最大值&#xff08;單位為字節&#xff09;。 文件緩存系統有兩種操作&#xff1a; 存儲文件&#xff08;put&#xff09;讀取文件&#xff08;get&#xff09; 操作命令為&#xff1a; put fileName …

Python中的sys.path與PYTHONPATH全解析:模塊導入路徑的底層機制與最佳實踐

在Python項目開發中&#xff0c;很多人遇到過類似“模塊導入失敗”、“路徑找不到”、“相對導入與絕對導入混亂”等問題。而這些問題的根源&#xff0c;幾乎都繞不開一個核心概念——Python模塊搜索路徑。 今天&#xff0c;我們圍繞sys.path 和 PYTHONPATH環境變量&#xff0…

python:如何調節機器學習算法的魯棒性,以支持向量機SVM為例,讓伙伴們看的更明白

魯棒性&#xff08;Robustness&#xff09;指模型在噪聲數據或異常值干擾下保持性能穩定的能力。想詳細了解的可參考本人之前的博文 python機器學習&#xff1a;評價智能學習算法性能與效果的常見術語&#xff1a;不收斂、過擬合、欠擬合、泛化能力、魯棒性一句話、一張圖給您…

號源加鎖升級思路(解決高并發問題)

原先邏輯鏈接&#xff1a;號源預約加鎖思路_java 預約 接口加鎖-CSDN博客 一、進行治療項目和號源數據緩存 1.新建一個定時任務&#xff0c;主要在凌晨時緩存治療項目和號源數據 1.1.類中使用redission獲取鎖&#xff08;用于分布式系統獲取數據&#xff0c;保證原子性&…

MCP革命:AI世界的“USB-C”接口如何重塑智能體與外部工具的連接

> 一條標準化的數據通道,讓AI從“對話專家”蛻變為“行動專家”,背后是一場由協議驅動的工具連接革命。 2024年11月,Anthropic公司開源了**Model Context Protocol(MCP)**。在短短9個月內,這項技術徹底改變了AI與外部世界的交互方式。截至2025年8月,MCP服務數量**從…

啟用“安全登錄”組合鍵(Ctrl+Alt+Delete)解鎖

文章目錄背景目標功能操作步驟效果背景 在日常工作中&#xff0c;我們有時需要讓電腦長期開機運行&#xff08;如處理長任務、作為服務器等&#xff09;。然而&#xff0c;這其中存在一個潛在風險&#xff1a;當電腦處于鎖屏或登錄界面時&#xff0c;如果有人無意中觸碰鍵盤比…

【08】C++實戰篇——C++ 生成動態庫.dll 及 C++調用DLL,及實際項目中的使用技巧

文章目錄一、創建動態庫dll (方法一)1 生成C 動態庫dll1.1 創建項目MyDLL1.2 編寫.h 和 .cpp文件1.3 設置 及 生成 DLL2 調用 C 動態庫dll2.1 創建C 空項目DLLtest2.2 動態庫配置 及代碼調用測試3 實際項目中的使用技巧3.1 設置dll輸出路徑3.2 設置頭文件引入路徑3.3 改進后 測…

kettle插件-kettle http client plus插件,輕松解決https接口無法調用文件流下載問題

場景&#xff1a;小伙伴在使用kettle調用https接口過程中無法正常調用&#xff0c;程序出錯問題&#xff0c;今天演示下用自研插件輕松解決這個問題。1、使用openssl 生成自簽名證書openssl req -x509 -newkey rsa:4096 -nodes -out cert.pem -keyout key.pem -days 3652、使用…