我正在阅读一本叫做Go in action的书,我对书中的goroutines部分有点困惑,基本上我想了解以下代码的两件事:
package main
import (
"fmt"
"runtime"
"sync"
"time"
)
var counter int = 0
var wg sync.WaitGroup
var mtx sync.Mutex
func main() {
wg.Add(2)
runtime.GOMAXPROCS(1)
go incCounter("A")
go incCounter("B")
wg.Wait()
fmt.Println(counter)
}
func incCounter(prefix string) {
fmt.Println("Started thread ", prefix)
defer wg.Done()
mtx.Lock()
{
fmt.Println("Incrementing counter from ", prefix)
counter = counter + 1
fmt.Println("Passing to another thread")
runtime.Gosched()
for i := 1; i < 100; i++ {
time.Sleep(1 * time.Second)
fmt.Println("Thread still executing ", prefix)
}
}
mtx.Unlock()
}
字符串
输出为:
Started thread B
Incrementing counter from B
Passing to another thread
Started thread A
Thread still executing B
Thread still executing B
Thread still executing B
Thread still executing B
型
1.为什么它首先执行goroutine B?因为在代码中,goroutine A首先出现,我希望它也首先运行。
- goroutine B使用.Gosched方法允许goroutine A开始执行,但是由于互斥锁被锁定,goroutine A将等待解锁。此时,我将GOMAXPROCS设置为只有一个逻辑处理器,为什么看起来两个goroutine并行运行?这实际上是应该发生的吗?
正如我所认为的,将gomaxprox设置为1将允许一次只执行一个goroutine,但在这种情况下,似乎并没有发生什么,实际上似乎两个goroutine是并行运行的。
1条答案
按热度按时间bqjvbblv1#
goroutine并发运行。这意味着,如果有可用的处理器,调度器可以调度它们并行运行。如果只有一个处理器可用,它们仍然会并发运行,但在任何给定的时刻只有一个goroutine会运行。
Go运行时并不保证哪个goroutine会先运行。所以一组新创建的goroutine的运行顺序是随机的,