您好,登錄后才能下訂單哦!
這篇文章主要介紹了golang如何實(shí)現(xiàn)并發(fā)求和,具有一定借鑒價(jià)值,感興趣的朋友可以參考下,希望大家閱讀完這篇文章之后大有收獲,下面讓小編帶著大家一起了解一下。
golang可以做服務(wù)器端開發(fā),但golang很適合做日志處理、數(shù)據(jù)打包、虛擬機(jī)處理、數(shù)據(jù)庫代理等工作。在網(wǎng)絡(luò)編程方面,它還廣泛應(yīng)用于web應(yīng)用、API應(yīng)用等領(lǐng)域。
使用golang并發(fā)求和,作為對(duì)golang并發(fā)的一個(gè)練習(xí).
func sum1(data []int) int { s := 0 l := len(data) for i := 0; i < l; i++ { s += data[i] } return s }
使用N個(gè)goroutine, 然后將N個(gè)分段的和寫入N個(gè)channel中:
func sum2(data []int) int { s := 0 l := len(data) const N = 5 seg := l / N var chs [N]<-chan int for i := 0; i < N; i++ { chs[i] = worker(data[i*seg : (i+1)*seg]) } for i := 0; i < N; i++ { s += <-chs[i] } return s } func worker(s []int) <-chan int { out := make(chan int) go func() { length := len(s) sum := 0 for i := 0; i < length; i++ { sum += s[i] } out <- sum }() return out }
對(duì)于一個(gè)求和的任務(wù)來說,用worker這種“模式”可能 太過麻煩,
直接一個(gè)函數(shù)寫出來:
func sum3(data []int) int { s := 0 l := len(data) const N = 5 seg := l / N var mu sync.Mutex var wg sync.WaitGroup wg.Add(N) // 直接加N個(gè) for i := 0; i < N; i++ { go func(ii int) { tmpS := data[ii*seg : (ii+1)*seg] ll := len(tmpS) mu.Lock() for i := 0; i < ll; i++ { s += tmpS[i] } mu.Unlock() wg.Done() // 一個(gè)goroutine運(yùn)行完 }(i) } wg.Wait() // 等N個(gè)goroutine都運(yùn)行完 return s }
注意sum3要在讀寫s的地方加鎖,因?yàn)閟可能被多個(gè)goroutine并發(fā)讀寫。
不過運(yùn)行結(jié)果是對(duì)的,看一下思路:
var sum4Tmp int var sum4mu sync.Mutex // 這個(gè)有data race問題,可以用WaitGroup改,只是提供一種思路 func sum4(data []int) int { //s := 0 l := len(data) const N = 5 seg := l / N for i := 0; i < N; i++ { go subsum4(data[i*seg : (i+1)*seg]) } // 這里是>1,因?yàn)橐懦齧ain // 這種方法不可靠,只是一種思路 for runtime.NumGoroutine() > 1 { } // go run -race sum.go會(huì)報(bào)data race問題 // main goroutine對(duì)它讀 // 別的goroutine會(huì)對(duì)它寫(go subsum4) return sum4Tmp } func subsum4(s []int) { length := len(s) sum := 0 sum4mu.Lock() for i := 0; i < length; i++ { sum += s[i] } sum4Tmp = sum4Tmp + sum defer sum4mu.Unlock() }
最后測(cè)試如下:
首先創(chuàng)建一個(gè)slice, 放1e8(1億)個(gè)整數(shù)(范圍[0,10))進(jìn)去,
func calcTime(f func([]int) int, arr []int, tag string) { t1 := time.Now().UnixNano() s := f(arr) t2 := time.Now().UnixNano() - t1 fmt.Printf("%15s: time: %d, sum: %d\n", tag, t2, s) } func main() { const MAX = 1e8 // 1億 arr := make([]int, MAX) for i := 0; i < MAX; i++ { arr[i] = rand.Intn(10) } calcTime(sum1, arr, "for") calcTime(sum2, arr, "worker") calcTime(sum3, arr, "WaitGroup") calcTime(sum4, arr, "NumGoroutine") }
我的筆記本輸出結(jié)果:
for: time: 61834200, sum: 450032946
worker: time: 51861100, sum: 450032946
WaitGroup: time: 153628200, sum: 450032946
NumGoroutine: time: 63791300, sum: 450032946
歡迎補(bǔ)充指正!
補(bǔ)充:Golang并發(fā)求和(競(jìng)爭(zhēng)而非分段)
如果要求2個(gè)goroutine并發(fā)完成1到100的和而不是分段的情況如何解決呢?
var wg sync.WaitGroup var ch chan int32 var receiveCh chan int32 func add(){ var sum int32 sum = 0 Loop: for { select { case val, ok := <-ch: if ok { atomic.AddInt32(&sum, val) } else { break Loop } } } receiveCh <- sum wg.Done() } func main() { wg.Add(3) ch = make(chan int32) receiveCh = make(chan int32, 2) go func(){ for i := 1; i <= 100; i++{ n := i //避免數(shù)據(jù)競(jìng)爭(zhēng) ch <- int32(n) } close(ch) wg.Done() }() go add() go add() wg.Wait() close(receiveCh) var sum int32 sum = 0 for res := range receiveCh{ sum += res } fmt.Println("sum:",sum) }
感謝你能夠認(rèn)真閱讀完這篇文章,希望小編分享的“golang如何實(shí)現(xiàn)并發(fā)求和”這篇文章對(duì)大家有幫助,同時(shí)也希望大家多多支持億速云,關(guān)注億速云行業(yè)資訊頻道,更多相關(guān)知識(shí)等著你來學(xué)習(xí)!
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如果涉及侵權(quán)請(qǐng)聯(lián)系站長(zhǎng)郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。