golang并發(fā)編程的實(shí)現(xiàn)
更新時(shí)間：2020年01月12日 16:04:31 作者：Cazy
這篇文章主要介紹了golang并發(fā)編程的實(shí)現(xiàn),文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧
go
main函數(shù)的執(zhí)行本身就是一個(gè)協(xié)程，當(dāng)使用go關(guān)鍵字的時(shí)候，就會創(chuàng)建一個(gè)新的協(xié)程
channel
channel 管道，用于在多個(gè)協(xié)程之間傳遞信號
無緩存管道
當(dāng)對無緩沖通道寫的時(shí)候，會一直阻塞等到某個(gè)協(xié)程對這個(gè)緩沖通道讀
阻塞場景：
- 通道中無數(shù)據(jù)，但執(zhí)行讀通道。
- 通道中無數(shù)據(jù)，向通道寫數(shù)據(jù)，但無協(xié)程讀取。
綜上，無緩存通道的讀寫必須同時(shí)存在，且讀寫分別在兩個(gè)不同的協(xié)程
func main(){
ch := make(chan int)
go func(ch chan int){
ch <-222
}(ch)
println(<-ch)
}
有緩沖管道
有緩存時(shí)可以向通道中寫入數(shù)據(jù)后直接返回，緩存中有數(shù)據(jù)時(shí)可以從通道中讀到數(shù)據(jù)直接返回，這時(shí)有緩存通道是不會阻塞的
阻塞場景：
- 通道的緩存無數(shù)據(jù)，但執(zhí)行讀通道。
- 通道的緩存已經(jīng)占滿，向通道寫數(shù)據(jù)，但無協(xié)程讀。
綜上，有緩沖通道的讀寫必須在兩個(gè)不同協(xié)程
func main() {
ch := make(chan int, 1) //長度為1的緩沖管道也是有緩沖管道
ch <- 333
go func(ch chan int) {
println(<-ch)
}(ch)
ch <- 333
}
sync.Mutex 和 sync.RwMutex
sync.Mutex 并發(fā)鎖，一次只可以加載一個(gè)并發(fā)鎖
sync.RwMutex 讀寫鎖，一次可以加載多個(gè)讀鎖和一個(gè)寫鎖。當(dāng)寫鎖存在時(shí)候，不能再加載讀鎖和寫鎖
sync.WaitGroup
阻塞等待所有任務(wù)完成之后再繼續(xù)執(zhí)行
WaitGroup在不方法中傳遞，需要傳指針
func main() {
var wg sync.WaitGroup
ch := make(chan int, 1000)
for i := 0; i < 1000; i++ {
wg.Add(1)
go doSomething(i, &wg, ch)
}
wg.Wait()
fmt.Println("all done")
for i := 0; i < 1000; i++ {
dd := <-ch
fmt.Println("from ch:"+strconv.Itoa(dd))
}
}
func doSomething(index int, wg *sync.WaitGroup, ch chan int) {
defer wg.Done()
fmt.Println("start done:" + strconv.Itoa(index))
//time.Sleep(20 * time.Millisecond)
ch <- index
}
以上就是本文的全部內(nèi)容，希望對大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。
相關(guān)文章
這篇文章主要介紹了基于golang中container/list包的用法說明，具有很好的參考價(jià)值，希望對大家有所幫助。一起跟隨小編過來看看吧2021-04-04
這篇文章給大家介紹GO實(shí)現(xiàn)協(xié)程池管理的方法，分別使用channel實(shí)現(xiàn)協(xié)程池和消費(fèi)者模式實(shí)現(xiàn)協(xié)程池，本文通過實(shí)例代碼給大家介紹的非常詳細(xì)，需要的朋友參考下吧2021-07-07
Go 語言的?strconv?包提供了用于基本數(shù)據(jù)類型之間轉(zhuǎn)換的函數(shù),本文主要介紹了Go 類型轉(zhuǎn)換工具包strconv包的用法,具有一定的參考價(jià)值,感興趣的可以了解一下2024-05-05
這篇文章主要為大家詳細(xì)介紹了8種超簡單的Golang生成隨機(jī)字符串方式,文中的示例代碼講解詳細(xì),感興趣的小伙伴可以跟隨小編一起學(xué)習(xí)一下2024-01-01
這篇文章主要介紹了Golang連接Redis數(shù)據(jù)庫的方法,本文給大家介紹的非常詳細(xì)，對大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值，需要的朋友可以參考下2020-12-12
Golang使用gzip壓縮字符減少redis等存儲占用的實(shí)現(xiàn)
本文主要介紹了Golang使用gzip壓縮字符減少redis等存儲占用的實(shí)現(xiàn)，文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2023-01-01
這篇文章主要介紹了Golang pipe在不同場景下遠(yuǎn)程交互，pipe實(shí)現(xiàn)從一個(gè)進(jìn)程重定向至另一個(gè)進(jìn)程，它是雙向數(shù)據(jù)通道，用于實(shí)現(xiàn)進(jìn)行間通信2023-03-03
本文給大家分享的是使用go語言編寫的TCP端口掃描器，可以選擇IP范圍，掃描的端口，以及多線程，有需要的小伙伴可以參考下。2015-03-03
Go語言atomic.Value如何不加鎖保證數(shù)據(jù)線程安全？
這篇文章主要介紹了Go語言atomic.Value如何不加鎖保證數(shù)據(jù)線程安全詳解，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪2023-05-05
在某些場景下，我們需要初始化一些資源。有時(shí)會采用延遲初始化的方式，在真正需要資源的時(shí)候才進(jìn)行初始化。在這種情況下，Go語言中的sync.Once提供一個(gè)優(yōu)雅且并發(fā)安全的解決方案，本文將對其進(jìn)行詳細(xì)介紹2023-04-04