您好,登錄后才能下訂單哦!
這篇文章主要介紹了Go語言同步等待組sync.WaitGroup結構體對象方法怎么用的相關知識,內容詳細易懂,操作簡單快捷,具有一定借鑒價值,相信大家閱讀完這篇Go語言同步等待組sync.WaitGroup結構體對象方法怎么用文章都會有所收獲,下面我們一起來看看吧。
在Go語言中,sync.WaitGroup結構體對象用于等待一組線程的結束;WaitGroup是go并發中最常用的工具,我們可以通過WaitGroup來表達這一組協程的任務是否完成,以決定是否繼續往下走,或者取任務結果;
結構如下所示:
type WaitGroup struct { noCopy noCopy state1 [3]uint32 }
在sync.WaitGroup結構體對象中有三個方法,Add()、Done()、Wait()
主要為WaitGroup的等待數+1或者+n;
Add()方法的定義如下:
func(*WaitGroup) Add()
Add()方法內部計數器加上delta,delta可以是負數;
如果內部計數器變為0,則Wait()方法會將處于阻塞等待的所有goroutine釋放;
如果計數器小于0,則調用panic()函數;
Add()方法加上正數的調用應在Wait()方法之前,否則Wait()方法可能只會等待很少的goroutine;
Add()方法在創建新的goroutine或者其它等待的事件之前調用;
Done函數調用的也是Add函數,主要用于-1操作;
Done()方法的定義如下:
func(wg *WaitGroup) Done()
Done()方法會減少WaitGroup計數器的值,一般在goroutine的最后執行;
阻塞當前協程,直到等待數歸為0才繼續向下執行;
Wait()方法的定義如下:
func (wg *WaitGroup) Wait()
Wait()方法會阻塞,知道WaitGroup計數器減為0.
在三個方法中,使用Add()方法添加計數,使用Done()方法減掉一個計數,如果計數不為0,則會阻塞Wait()方法的運行;
一個goroutine調用Add()方法來設定等待的goroutine的數量;
每個被等待的goroutine在結束時調用Done()方法;
在主goroutine里可以調用Wait()方法阻塞至所有goroutine結束。
關于“Go語言同步等待組sync.WaitGroup結構體對象方法怎么用”這篇文章的內容就介紹到這里,感謝各位的閱讀!相信大家對“Go語言同步等待組sync.WaitGroup結構體對象方法怎么用”知識都有一定的了解,大家如果還想學習更多知識,歡迎關注億速云行業資訊頻道。
免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。