go 協程并發數控制

錯誤的寫法:
這里的<-ch 是為了從channel 中讀取 數據,為了不使channel通道被寫滿,阻塞 go 協程數的創建。但是請注意,go workForDraw(v, &wg) 是不阻塞后續的<-ch 執行的,所以就一直go workForDraw(v, &wg) 拉起新的協程。這么是達不到控制協程并發數10 的目的
在這里插入圖片描述

正確的寫法:
直接將<-ch 寫入workForDraw 方法里面的最后,這樣只有 該 go 協程的任務 workForDraw 完成之后才會執行 <-ch ,使channel管道中的緩沖釋放一個。
這樣就把 <-ch 和 go 協程持有的任務 workForDraw 強制綁定,只有完成任務才會 <-ch ,如果不完成,只要channel通道的緩沖不滿10 就可以繼續創建新的go 協程持有workForDraw。直到緩沖滿到10 為止

func ListenRedisQue() {ch := make(chan int, 10)var wg sync.WaitGroupfor {keyData, err := config.GetRedisClient().Keys(global.RedisQueueKey + "*").Result()fmt.Println("ListenRedisQue start for", keyData)if err != nil {fmt.Println("redis queue empty!!")return}for _, v := range keyData {ch <- 1wg.Add(1)go workForDraw(v, &wg, ch)}wg.Wait()}
}func workForDraw(queueKey string, wg *sync.WaitGroup, ch chan int) {defer wg.Done()<-ch 
}

在這里插入圖片描述
另外切記 在for 循環中,一定不能初始化 db,或者其他消耗資源,可循環使用的動作,要將初始化提到for之外,將資源以變量或者指針形式傳入 for 邏輯內部使用

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

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

相關文章

使用 NLP 進行文本摘要

一、說明 文本摘要是為較長的文本文檔生成簡短、流暢且最重要的是準確摘要的過程。自動文本摘要背后的主要思想是能夠從整個集合中找到最重要信息的一小部分&#xff0c;并以人類可讀的格式呈現。隨著在線文本數據的增長&#xff0c;自動文本摘要方法可能會非常有用&#xff0c…

C語言好題解析(一)

目錄 選擇題1選擇題2選擇題3選擇題4編程題一 選擇題1 執行下面程序&#xff0c;正確的輸出是&#xff08; &#xff09;int x 5, y 7; void swap() {int z;z x;x y;y z; } int main() {int x 3, y 8;swap();printf("%d,%d\n",x, y);return 0; }A: 5,7 B: …

H5前端外包開發框架排名

以下是一些常見的網頁前端開發框架以及它們的排名和特點。請注意&#xff0c;隨著時間的推移&#xff0c;框架的排名和特點可能會有所變化。不同的項目和團隊對于框架的選擇會受到多個因素的影響&#xff0c;包括開發團隊的技能、項目的規模和要求、性能需求等。北京木奇移動技…

try-with-resource

git https://gitee.com/my739168148/auto-close-try-with-resource.git 限制 try-with-resource是java7版本引入的。 java版本說明 Autocloseable 只要是java.lang.Autocloseable接口的實現類&#xff0c;那么都可以使用try-with-resource來自動關閉資源。 使用 JDK1.8開…

【網絡】網絡層——IP協議

&#x1f431;作者&#xff1a;一只大喵咪1201 &#x1f431;專欄&#xff1a;《網絡》 &#x1f525;格言&#xff1a;你只管努力&#xff0c;剩下的交給時間&#xff01; 網絡層中&#xff0c;IP協議首部和有效載荷組成的完整數據稱為數據報。 IP協議 &#x1f349;TCP和IP的…

C# Linq源碼分析之Take (二)

概要 本文主要分析Linq中Take帶Range參數的重載方法的源碼。 源碼分析 基于Range參數的Take重載方法&#xff0c;主要分成兩部分實現&#xff0c;一部分是Range中的開始和結束索引都是正數的情況例如取第一個到第三個元素的情況&#xff1b;另一部分是開始或結束索引中有倒數…

華為AI戰略的CANN

基于TVM的華為昇騰體系中—— 異構計算架構&#xff08;CANN&#xff09;是對標英偉達的CUDA CuDNN的核心軟件層&#xff0c;向上支持多種AI框架&#xff0c;向下服務AI處理器&#xff0c;發揮承上啟下的關鍵作用&#xff0c;是提升昇騰AI處理器計算效率的關鍵平臺 主要包括有…

ES安裝問題匯總

max file descriptors [4096] for elasticsearch process is too low, increase to at least [65535] 問題描述 ES啟動報錯。其原因是ES需要的的最小max file descriptors為65535&#xff0c;我們設置的是4096&#xff0c;需要增大max file descriptors的值。 解決方案 調大…

“new出對象“原理的深層解密

&#x1f388;個人主頁:&#x1f388; :???初階牛??? &#x1f43b;推薦專欄1: &#x1f354;&#x1f35f;&#x1f32f;C語言初階 &#x1f43b;推薦專欄2: &#x1f354;&#x1f35f;&#x1f32f;C語言進階 &#x1f511;個人信條: &#x1f335;知行合一 &#x1f…

正規的股票杠桿公司_杠桿公司排名(2023年版的)

本文將介紹一些正規的股票杠桿公司&#xff0c;并重點介紹配先查網站的特點&#xff0c;該網站是一家專業查詢實盤杠桿平臺的網站&#xff0c;提供相關信息和參考。 杠桿公司排名&#xff08;2023年版的&#xff09;&#xff1a;廣盛網、一鼎盈、尚紅網、盛多網、紅騰網、富燈…

Oracle/PL/SQL奇技淫巧之ROWNUM偽列

ROWNUM偽列 ROWNUM是一個偽列&#xff0c;它是根據每次查詢的結果動態生成的一列遞增編號&#xff0c;表示 Oracle 從表中選擇該行的順序&#xff0c;選擇的第一行ROWNUM為1&#xff0c;第二行ROWNUM為2&#xff0c;以此類推。 注意1&#xff1a; ROWNUM偽列是在WHERE子句之…

Mybatis——返回值(resultType&resultMap)詳解

之前的文章里面有對resultType和resultMap的簡單介紹這一期出點詳細的 resultType&#xff1a; 1&#xff0c;返回值為簡單類型。 直接使用resultType“類型”&#xff0c;如string&#xff0c;Integer等。 String getEmpNameById(Integer id); <!-- 指定 result…

Linux內核源碼剖析之TCP保活機制(KeepAlive)

寫在前面&#xff1a; 版本信息&#xff1a; Linux內核2.6.24&#xff08;大部分centos、ubuntu應該都在3.1。但是2.6的版本比較穩定&#xff0c;后續版本本質變化也不是很大&#xff09; ipv4 協議 https://blog.csdn.net/ComplexMaze/article/details/124201088 本文使用案例…

高級AI賦能Fortinet FortiXDR解決方案

擴展檢測和響應 (XDR&#xff1a;Extended Detection and Response) 解決方案旨在幫助組織整合分布式安全技術&#xff0c;更有效地識別和響應活動的威脅。雖然 XDR 是一種新的技術概念&#xff0c;但其構建基礎是端點檢測和響應 (EDR&#xff1a;Endpoint Detection and Respo…

代碼隨想錄算法訓練營第50天|動態規劃part11

8.16周三 123.買賣股票的最佳時機III 188.買賣股票的最佳時機IV 詳細布置 123.買賣股票的最佳時機III 題目&#xff1a;最多買賣兩次 題解&#xff1a; 1、 dp[i][0]沒有操作 &#xff08;其實我們也可以不設置這個狀態&#xff09; dp[i][1]第一次持有股票 dp[i][2]第一…

CSDN?索尼 toio?應用創意開發征集征集活動 創意公示! 入選的用戶看過來~

索尼toio?應用創意開發征集活動自開啟以來&#xff0c;收到了很多精彩的創意&#xff01;接下來&#xff0c;我們將公示入選的20個優秀創意和10個入圍創意&#xff0c;以下提到ID的小伙伴注意啦&#xff0c;你們將有機會順利進入活動的第二階段&#xff0c;注意查收你們的信箱…

javaScript:快樂學習計時器

目錄 一.前言 二.計時器 1.計時器的分類 2. 創建計時器的方式 創建間隔計時器 創建方式三種 1.匿名函數 2.使用函數直接作為計時器的執行函數 2.使用函數直接作為計時器的執行函數,用字符串的形式寫入 3.計時器的返回值 4.清除計時器 5.延遲計時器 相關代碼 一.前言 在…

Linux--實用指令與方法(部分)

下文主要是一些工作中零碎的常用指令與方法 實用指令與方法&#xff08;部分&#xff09; linux長時間保持ssh連接 這個問題的原因是&#xff1a;設置檢測時間太短&#xff0c;或者沒有保持tcp長連接。 解決步驟&#xff1a; 步驟1&#xff1a;打開sshd配置文件&#xff0…

nbcio-boot從3.0升級到3.1的出現用戶管理與數據字典bug

升級后出現 系統管理里的用戶管理出現下面問題 2023-08-17 09:44:38.902 [http-nio-8080-exec-4] [1;31mERROR[0;39m [36mo.jeecg.common.exception.JeecgBootExceptionHandler:69[0;39m - java.lang.String cannot be cast to java.lang.Long java.lang.ClassCastException:…

【JS 線性代數算法之向量與矩陣】

線性代數算法 一、向量的加減乘除1. 向量加法2. 向量減法3. 向量數乘4. 向量點積5. 向量叉積 二、矩陣的加減乘除1. 矩陣加法2. 矩陣減法3. 矩陣數乘4. 矩陣乘法 常用數學庫 線性代數是數學的一個分支&#xff0c;用于研究線性方程組及其解的性質、向量空間及其變換的性質等。在…