卓越飞翔博客卓越飞翔博客

卓越飞翔 - 您值得收藏的技术分享站
技术文章64334本站已运行4115

为什么 go 例程会有这样的行为?

为什么 go 例程会有这样的行为?

php小编西瓜为您解答关于"go 例程行为的原因"的问题。go语言中的例程(goroutine)是一种轻量级的并发机制,可以实现并发执行的效果。然而,在某些情况下,go例程的行为可能会出现一些意料之外的结果。这主要是因为go例程的调度机制以及内存模型的特性所导致的。在深入理解go语言的例程行为之前,我们需要了解这些特性以及它们对程序行为的影响。

问题内容

我正在读一本叫做《Go in action》的书,我对书中的 goroutine 部分感到有点困惑,基本上我想了解有关以下代码的两件事:

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 首先出现,所以我希望它也先运行。
  2. goroutine B 使用 .Gosched 方法让 goroutine A 开始执行,但由于互斥体被锁定,goroutine A 将等待解锁。此时我将GOMAXPROCS设置为只有一个逻辑处理器,为什么看起来两个goroutine是并行运行的呢?这真的应该发生吗?

正如我所言,将 gomaxprox 设置为 1 将允许一次只执行一个 Goroutine,但在这种情况下,似乎并不是这样,实际上两个 Goroutine 都在并行运行。

解决方法

Goroutines 并发运行。这意味着,如果有可用的处理器,调度程序可以安排它们并行运行。如果只有一个处理器可用,它们仍然会并发运行,但在任何给定时刻只有一个 goroutine 运行。

Go 运行时不保证哪个 goroutine 将首先运行。所以一组新创建的goroutine的运行顺序是随机的,

卓越飞翔博客
上一篇: 使用 JQ 的 Golang 实现时具有“列表中的值”条件
下一篇: Gin Gonic - URL 内的冒号
留言与评论(共有 0 条评论)
   
验证码:
隐藏边栏