Q1:Go協程、Channel通道 被close后,讀會帶來什么問題?

在 Go 語言中,Channel(通道)關閉后讀取的行為是一個常見但需要謹慎處理的問題。以下是詳細的分析和注意事項:

1. 關閉 Channel 后讀取的行為

(1) 讀取已關閉的 Channel
  • 剩余數據仍可讀取
    關閉 Channel 后,剩余的數據可以繼續讀取,直到所有數據被讀取完畢。例如:

    ch := make(chan int, 3)
    ch <- 1
    ch <- 2
    close(ch)
    fmt.Println(<-ch) // 輸出 1
    fmt.Println(<-ch) // 輸出 2
    fmt.Println(<-ch) // 輸出 0(零值)
    
    • 輸出解釋:前兩次讀取會獲取到 Channel 中已有的數據(1 和 2),第三次讀取時 Channel 已無數據,因此返回 int 類型的零值 0
  • 讀取零值
    當 Channel 被關閉且內部無數據時,繼續讀取會返回對應類型的零值(如 int 的 0、string"" 等),但不會觸發 panic。

(2) 判斷 Channel 是否關閉
  • 通過 value, ok := <-ch 判斷
    如果 okfalse,表示 Channel 已關閉且無數據可讀:

    value, ok := <-ch
    if !ok {fmt.Println("Channel is closed")
    }
    
  • 通過 for range 遍歷
    遍歷時,若 Channel 被關閉,循環會自動退出:

    for v := range ch {fmt.Println(v) // 當 Channel 關閉時,循環終止
    }
    

2. 常見問題與注意事項

(1) 寫入已關閉的 Channel
  • 會觸發 panic
    關閉 Channel 后,不能再向其發送數據,否則會引發 panic: send on closed channel
    ch := make(chan int)
    close(ch)
    ch <- 1 // panic: send on closed channel
    
(2) 多次關閉 Channel
  • 會觸發 panic
    對已關閉的 Channel 調用 close 會導致 panic: close of closed channel
    ch := make(chan int)
    close(ch)
    close(ch) // panic: close of closed channel
    
(3) 遍歷未關閉的 Channel
  • 可能導致死鎖
    如果使用 for range 遍歷 Channel 但未關閉它,程序會一直阻塞等待數據,最終觸發死鎖錯誤:
    ch := make(chan int, 10)
    for i := 1; i <= 3; i++ {ch <- i
    }
    // 未關閉 Channel
    for v := range ch {fmt.Println(v) // 程序會一直阻塞,最終報錯:// fatal error: all goroutines are asleep - deadlock!
    }
    

3. 最佳實踐

  1. 確保 Channel 在適當的時候關閉

    • 通常由生產者(發送數據的協程)負責關閉 Channel。
    • 使用 sync.Once 確保 Channel 只關閉一次(防止 panic):
      var once sync.Once
      closeChan := func() {once.Do(func() {close(ch)})
      }
      
  2. 處理零值的情況

    • 如果業務邏輯中零值有意義(如 0 表示有效數據),需通過 value, ok := <-ch 區分正常數據和 Channel 關閉后的零值。
  3. 避免死鎖

    • 使用 for range 遍歷 Channel 時,必須在數據發送完成后關閉 Channel
  4. 使用帶緩沖的 Channel

    • 緩沖 Channel(如 make(chan int, N))可以在未滿時異步發送數據,減少阻塞,但需注意緩沖區大小與并發量的匹配。

4. 示例代碼

package mainimport ("fmt""sync"
)func main() {ch := make(chan int, 3)go func() {for i := 1; i <= 3; i++ {ch <- i}close(ch) // 生產者關閉 Channel}()var once sync.OncecloseChan := func() {once.Do(func() {close(ch)})}// 消費者讀取數據for {value, ok := <-chif !ok {fmt.Println("Channel closed")break}fmt.Println("Received:", value)}// 安全關閉 Channel(即使多次調用也不會 panic)closeChan()closeChan()
}

總結

操作結果
讀取已關閉的 Channel讀取剩余數據 → 零值,不會 panic
寫入已關閉的 Channelpanic: send on closed channel
多次關閉 Channelpanic: close of closed channel
遍歷未關閉的 Channel死鎖(fatal error: deadlock)
使用 sync.Once 關閉 Channel安全地確保 Channel 只關閉一次

正確處理 Channel 的關閉和讀取是 Go 并發編程的關鍵,能避免 panic 和死鎖問題。

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

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

相關文章

【AI Study】第三天,Python基礎 - 同NumPy類似的類庫

學習計劃&#xff1a;AI Study&#xff0c;學習計劃源碼地址&#xff1a;https://github.com/co-n00b/AI-Study.git 2025-05-23 在學習NumPy的過程中&#xff0c;除了了解NumPy之外&#xff0c;我們也對比看看其他類似的類庫都有什么&#xff1f;各自的優缺點是什么&#xff1…

基于aspnet,微信小程序,mysql數據庫,在線微信小程序汽車故障預約系統

詳細視頻:【基于aspnet,微信小程序,mysql數據庫,在線微信小程序汽車故障預約系統。-嗶哩嗶哩】 https://b23.tv/zfqLWPV

人工智能100問?第32問:什么是遷移學習?

目錄 一、通俗解釋 二、專業解析 三、權威參考 遷移學習就是讓AI把在一個任務中學到的本事&#xff0c;拿來加速另一個任務的學習&#xff0c;實現“舉一反三”。 一、通俗解釋 想象你已經學會了打乒乓球&#xff0c;現在去學打網球&#xff0c;是不是會學得更快&#xff…

Linux之概述和安裝vm虛擬機

文章目錄 操作系統概述硬件和軟件操作系統常見操作系統 初識LinuxLinux的誕生Linux內核Linux發行版 虛擬機介紹虛擬機 VMware WorkStation安裝虛擬化軟件VMware WorkStation 安裝查看VM網絡連接設置VM存儲位置 在VMware上安裝Linux(發行版CentOS7)安裝包獲取CentOS7 安裝 Mac系…

兩個mysql的maven依賴要用哪個?

背景 <dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId> </dependency>和 <dependency><groupId>com.mysql</groupId><artifactId>mysql-connector-j</artifactId> &l…

復雜項目中通過使用全局變量解決問題的思維方式

最近接手了一個公司的老系統的PHP項目&#xff0c;里面的代碼比較混亂&#xff0c;排查解決了一個問題&#xff0c;決定將這個思路記錄下來&#xff0c;希望能幫助更多的人。 其中一部分的代碼信息如下&#xff1a; 備注&#xff1a;為了避免公司的相關數據信息暴露&#xff0…

V9數據庫替換授權

文章目錄 環境文檔用途詳細信息 環境 系統平臺&#xff1a;Linux x86-64 Red Hat Enterprise Linux 7 版本&#xff1a;9.0 文檔用途 1、本文檔用于指導V9數據庫替換授權。 2、V9數據庫授權文件為license.dat。 詳細信息 1、上傳新的授權文件到服務器并修改授權文件屬主為…

初識 Flask 框架

目錄 1. Flask 框架概述 1.1 安裝 Flask 1.2 創建你的第一個 Flask 應用 1.3 運行 Flask 應用 2. Flask 路由與視圖函數 2.1 動態路由 2.2 支持多種 HTTP 請求方法 2.3 使用 Jinja2 模版渲染 HTML 2.5 模版繼承與塊 3. Flask 表單處理與用戶輸入 3.1 安裝 Flask-WTF …

《深入剖析:Python自動化測試框架之unittest與pytest》

unittest作為Python標準庫的一部分&#xff0c;猶如一位沉穩可靠的“老工匠”&#xff0c;默默為無數項目提供著堅實的測試基礎。它誕生于Python社區長期的實踐沉淀&#xff0c;擁有一套標準化的測試體系&#xff0c;就像一套精密的儀器&#xff0c;各個部件各司其職。 unitte…

【Python 命名元祖】collections.namedtuple 學習指南

&#x1f4da; collections.namedtuple 學習指南 命名元組&#xff08;namedtuple&#xff09;是 Python collections 模塊中一種增強型元組&#xff0c;支持通過字段名訪問元素&#xff0c;同時保持元組的內存效率和不可變性。 一、基礎用法 1. 定義命名元組 from collectio…

iOS知識復習

block原理 OC block 是個結構體&#xff0c;內部有個一個結構體成員 專門保存 捕捉對象 Swift閉包 是個函數&#xff0c;捕獲了全局上下文的常量或者變量 修改數組存儲的內容&#xff0c;不需要加_block,修改數組對象本身時需要 weak原理 Weak 哈希表 &#xff08;散列表&a…

手眼標定:九點標定、十二點標定、OpenCV 手眼標定

因為一直使用6軸協作機器人&#xff0c;且主要應用是三維視覺&#xff0c;平常的手眼標定基本都是基于OpenCV來計算的&#xff0c;聽說有九點標定和十二點標定&#xff0c;順便了解下。 目錄 1.九點標定1.1 基本原理1.2 關于最小二乘法1.3 具體示例 2.十二點標定3.OpenCV 手眼標…

CSS之元素定位

元素定位 一、什么是元素定位 元素定位&#xff08;CSS Positioning&#xff09; 是指通過CSS的 position 屬性控制HTML元素在頁面中的布局方式。它決定了元素如何相對于其父元素、視口或其他元素進行位置調整。 CSS的 position 屬性用于控制元素在頁面上的定位方式&#xff…

測試工程師如何通俗理解和入門RAG:從“查資料”到“寫答案”的智能升級

1. 為什么要學習RAG?——從“查資料”到“寫答案”的飛躍 背景:你已經掌握了Embedding技術,能將文檔、代碼、測試用例等離散信息轉化為向量,用于相似度匹配。 痛點:但僅靠向量匹配找到相關文檔后,如何快速生成答案?如何避免“找到文檔卻不會總結”的尷尬? RAG的價值:…

數量優勢:使用Bagging和Boosting的集成模型

文章目錄 裝袋法&#xff08;Bagging&#xff09;和提升法&#xff08;Boosting&#xff09;利用集成學習創建強大的模型裝袋法&#xff08;Bagging&#xff09;&#xff1a;為機器學習模型增加穩定性裝袋法示例 提升法&#xff08;Boosting&#xff09;&#xff1a;減少弱學習…

5G基站選擇±10ppm晶振及低相噪技術解析

在5G通信技術飛速發展的時代&#xff0c;5G基站作為核心基礎設施&#xff0c;其性能的優劣直接影響著整個通信網絡的質量。晶振作為5G基站中的關鍵器件&#xff0c;對基站的頻率穩定性、信號傳輸質量等起著至關重要的作用。 5G基站對晶振的要求 &#xff08;一&#xff09;高…

嵌入式<style>設計模式

每天分享一個web前端開發技巧。 今天分享的主題是&#xff0c;如何提升前端代碼的內聚性。我們在寫<style></style>的時候&#xff0c;往往把大量無關聯的樣式寫在同一個<style>下&#xff0c;而且離相關的html元素很遠&#xff0c;這樣導致每次想修改某個元…

簡單數學板子和例題

線性丟番圖方程 axbyc dgcd(a,b)&#xff0c;若c|d&#xff0c;有無窮整數解 x x 0 b d n , y y 0 ? a d n xx_0{b\over d}n,yy_0-{a\over d}n xx0?db?n,yy0??da?n POJ 1265 poj真難用&#xff0c;abs一直報錯&#xff0c;萬能頭也不能用&#xff0c;給我調紅溫了 …

深度解析視頻剪輯SDK開發:從AI字幕提取到多端原生插件集成-優雅草卓伊凡

深度解析視頻剪輯SDK開發&#xff1a;從AI字幕提取到多端原生插件集成-優雅草卓伊凡 引言&#xff1a;視頻剪輯技術的演進與市場需求 近年來&#xff0c;短視頻和社交媒體的爆發式增長推動了視頻剪輯技術的快速發展。優雅草卓伊凡及其團隊近期接到一個客戶需求&#xff1a;開…

對WireShark 中的EtherCAT抓包數據進行解析

對WireShark 中的EtherCAT抓包數據進行解析 EtherCAT數據包結構 EtherCAT數據幀結構如下&#xff1a; 采用 Python 實現對 EtherCAT 數據包進行解析 import numpy as np import matplotlib.pyplot as plt from IPython import embed from collections import Counter import …