go - 为什么会导致 goroutine 创建的测量时间不同？

Question

考虑以下应用程序，旨在测量 goroutine 创建延迟。假设我们使用 GOMAXPROCS=2 运行。

package main

import "fmt"
import "time"

const numRuns = 10000

type  timeRecord struct{
    Ts time.Time
    Msg string
}

var timeStamps []timeRecord

func threadMain(done chan bool) {
    timeStamps = append(timeStamps, timeRecord{time.Now(), "Inside thread"})
    done <- true
}

func main() {
    timeStamps = make([]timeRecord, 0, numRuns*2)
    done := make(chan bool)
    dummy := 0
    for i := 0; i < numRuns; i++ {
        timeStamps = append(timeStamps, timeRecord{time.Now(), "Before creation"})
        go threadMain(done)
        <-done
    }

    // Regularize
    regularizedTime := make([]time.Duration, numRuns*2)
    for i := 0; i < len(timeStamps) ; i++ {
        regularizedTime[i] = timeStamps[i].Ts.Sub(timeStamps[0].Ts)
    }

    // Fake timetraced
    fmt.Printf("%6d ns (+%6d ns): %s\n", 0, 0, timeStamps[0].Msg)
    for i := 1; i < len(timeStamps) ; i++ {
        fmt.Printf("%8d ns (+%6d ns): %s\n", regularizedTime[i], (regularizedTime[i] - regularizedTime[i-1]).Nanoseconds(), timeStamps[i].Msg)
    }
}

在我的服务器上，从 Before creation 到 Inside thread，这始终输出大约一个中值 260 ns delta。现在考虑主要方法的以下变体。

timeStamps = make([]timeRecord, 0, numRuns*2)
done := make(chan bool)
dummy := 0
for i := 0; i < numRuns; i++ {
    timeStamps = append(timeStamps, timeRecord{time.Now(), "Before creation"})
    go threadMain(done)
    for j := 0; j < 1000; j++ {
        dummy += j
    }
    <-done
}

在这种变化下，相同的时间增量大约需要 890 ns。

显然，确切的数字是特定于机器的，但数字之间的差异很好奇。从逻辑上讲，如果我在“创建前”和“内部线程”之间进行测量，在 go 语句之后添加额外的逻辑似乎不应该增加时间，但确实如此。

有没有人知道为什么时间增加没有发生在预期的位置？

Answer 1

Go 调度器是协作的。它只能在程序的某些点将当前 goroutine 切换到另一个 goroutine，例如函数调用、读取/写入 channel 等。我希望您观察到的差异是由于 goroutine 稍后启动(之后添加的 for 循环)。