当增加显式调用工作线程时， gomaxprocs 将不再生效

积累知识，胜过积蓄金银！毕竟在Golang开发的过程中，会遇到各种各样的问题，往往都是一些细节知识点还没有掌握好而导致的，因此基础知识点的积累是很重要的。下面本文《当增加显式调用工作线程时， gomaxprocs 将不再生效》，就带大家讲解一下知识点，若是你对本文感兴趣，或者是想搞懂其中某个知识点，就请你继续往下看吧~

我如何使用gomaxprocs？下面的代码设置了 gomaxprocs，但随后会产生更多的工作线程。我预计有 2 个进程，但 5 个进程仍在运行。

package main

import (
    "fmt"
    "runtime"
    "sync"
    "time"
)

func worker(i int, waiter chan struct{}, wg *sync.WaitGroup) {
    defer func(waiter chan struct{}, wg *sync.WaitGroup) {
        fmt.Printf("worker %d done\n", i)
        wg.Done()
        <-waiter

    }(waiter, wg)
    fmt.Printf("worker %d starting\n", i)
    time.Sleep(time.Second)
}
func main() {
    runtime.GOMAXPROCS(2)
    var concurrency = 5
    var items = 10

    waiter := make(chan struct{}, concurrency)
    var wg sync.WaitGroup

    for i := 0; i < items; i++ {
        wg.Add(1)
        waiter <- struct{}{}
        go worker(i, waiter, &wg)
    }
    wg.Wait()
}

正确答案

Go 对于 C/C++ 程序员所认为的线程有三个概念：G、P、M。

• M = 实际线程
• G = Goroutines（即程序中的代码）
• P = 处理器

没有用于限制 Ms 数量的 Go API。没有用于限制 G 数量的 API - 每次调用 go func(...) 时都会创建一个新的。 GOMAXPROCS 东西是用来限制 Ps 的。

每个 P 用于跟踪某些运行 Goroutine 的运行时状态。

您应该将 GOMAXPROCS 视为致力于运行 Goroutine 的 Ms 峰值数量。 （还有其他的 Ms 不运行 Goroutine，但处理垃圾收集任务并充当模板线程，用于根据需要创建新的 Ms 等。一些 Ms 专门用于保存运行时状态，而一些 Go 代码被阻塞在系统调用内。）

因此，就程序中的代码而言，GOMAXPROCS 是 Go 代码执行并行程度的约束。当正在运行的 Goroutine 达到阻塞点时，它会被暂停，并且它的 P 用于恢复其他未阻塞的 Goroutine 的执行。

今天带大家了解了的相关知识，希望对你有所帮助；关于Golang的技术知识我们会一点点深入介绍，欢迎大家关注golang学习网公众号，一起学习编程~