在Go語言中，使用goroutine可以實(shí)現(xiàn)并發(fā)執(zhí)行任務(wù)，而sync.WaitGroup則是一種同步機(jī)制，用于等待一組goroutine的完成。然而，php小編香蕉發(fā)現(xiàn)，在某些情況下，使用帶有sync.WaitGroup的goroutine可能會(huì)導(dǎo)致結(jié)果不一致的問題。這種問題通常發(fā)生在多個(gè)goroutine同時(shí)修改共享變量的情況下，由于goroutine的執(zhí)行順序不確定，可能會(huì)導(dǎo)致最終結(jié)果的不一致性。在本文中，我們將探討這個(gè)問題的原因，并提供一些解決方案來確保goroutine之間的結(jié)果一致性。
問題內(nèi)容
我正在嘗試使用 goroutine（在 Go lang 中）計(jì)算小于任意整數(shù) i 的素?cái)?shù)數(shù)量。
例如，如果 i 為 100，則結(jié)果應(yīng)為 25。
以下是我當(dāng)前的實(shí)現(xiàn)：
package "main"
import (
"fmt"
"math"
"sync"
"time"
)
var wg sync.WaitGroup
func isprime(x int) bool {
if x == 2 {
return true
}
if x == 1 || x%2 == 0 {
return false
}
var xi = float64(x)
for i := 3; float64(i) < (math.Pow(xi, 0.5) + 1.0); i += 2.0 {
if x%i == 0 {
return false
}
}
return true
}
func main() {
fmt.Print("Till what number should I count primes? ")
var i int
fmt.Scan(&i)
r := 0
pr := &r
fmt.Println("Counting primes till ", i)
start := time.Now()
for x := 0; x <= i; x++ {
wg.Add(1)
go func(n int) {
defer wg.Done()
if isprime(n) {
*pr += 1
}
}(x)
}
wg.Wait()
elapsed := time.Since(start).Seconds()
fmt.Println("Counted", r, "primes")
fmt.Println("took", elapsed, "seconds")
}
登錄后復(fù)制
當(dāng)我運(yùn)行這個(gè)程序時(shí)，我得到了較小的 i 值的正確結(jié)果（直到大約 1000）
但是對(duì)于較大的 i 值，結(jié)果不一致并且不正確。
? ./main Till what number should I count primes? 10000 Counting primes till 10000 Counted 1228 primes took 0.006776541 seconds ? ./main Till what number should I count primes? 10000 Counting primes till 10000 Counted 1227 primes took 0.004183875 seconds ? ./main Till what number should I count primes? 1000000 Counting primes till 1000000 Counted 78254 primes took 0.441985921 seconds ? ./main Till what number should I count primes? 1000000 Counting primes till 1000000 Counted 78327 primes took 0.430042047 seconds
登錄后復(fù)制
隨著 i 的值變大，結(jié)果波動(dòng)增大。是什么原因造成的？有什么方法可以使其一致且正確嗎？
解決方法
您有一個(gè)共享變量，但沒有適當(dāng)?shù)耐健４嬖诟?jìng)爭(zhēng)條件（*pr += 1）。在共享變量前后添加互斥體修復(fù)它（mu.Lock()、mu.Unlock()）。
代碼：
var wg sync.WaitGroup
var mu sync.Mutex
func main() {
fmt.Print("Till what number should I count primes? ")
var i int
fmt.Scan(&i)
r := 0
pr := &r
fmt.Println("Counting primes till ", i)
start := time.Now()
for x := 0; x <= i; x++ {
wg.Add(1)
go func(n int) {
defer wg.Done()
if isprime(n) {
mu.Lock() // <= lock
*pr += 1
mu.Unlock() // <= unlock
}
}(x)
}
wg.Wait()
elapsed := time.Since(start).Seconds()
fmt.Println("Counted", r, "primes")
fmt.Println("took", elapsed, "seconds")
}
登錄后復(fù)制
輸出：
Till what number should I count primes? 1000000 Counting primes till 1000000 Counted 78498 primes took 0.6783484 seconds Till what number should I count primes? 1000000 Counting primes till 1000000 Counted 78498 primes took 0.5428273 seconds Till what number should I count primes? 1000000 Counting primes till 1000000 Counted 78498 primes took 0.5521617 seconds
登錄后復(fù)制
