runtime.GOMAXPROCS(1)和协程的关系。

红太狼 2022-09-04 09:53 129阅读 0赞

runtime.GOMAXPROCS(1)：只允许使用一个操作系统线程

### 代码 ###

package main
    
    import (
    	"fmt"
    	"runtime"
    	"sync"
    )
    
    func main() { 
    	runtime.GOMAXPROCS(1)//可以用的操作系统栈的个数
    	count := 10
    	wg := sync.WaitGroup{ }//sync包中的WaitGroup实现了一个类似任务队列的结构，你可以向队列中加入任务，任务完成后就把任务从队列中移除，如果队列中的任务没有全部完成，队列就会触发阻塞以阻止程序继续运行，
    	wg.Add(count * 2)//任务是执行20次Done
    	for i := 0; i < count; i++ { 
    		go func() { 
    			fmt.Printf("[%d]", i)
    			wg.Done()//将任务队列中的任务数量-1，其实.Done就是.Add(-1)
    		}()
    	}
    	for i := 0; i < count; i++ { 
    		go func(i int) { 
    			fmt.Printf("-%d-", i)
    			wg.Done()
    		}(i)
    	}
    	fmt.Println("wait start")
    	wg.Wait()
    	fmt.Println("\nwait end")
    }
    func init() { 
    	fmt.Println("Current Go Version:", runtime.Version())//输出当前go的版本
    }

### 输出 ###

byte$ghq# go run main.go
    Current Go Version: go1.16.5
    wait start
    -9-[10][10][10][10][10][10][10][10][10][10]-0--1--2--3--4--5--6--7--8-
    wait end

为什么会是这个样子呢？其实早期版本不是这样，早期版本对上述代码的输出是：

Current Go Version: go1.4
    wait start
    [10][10][10][10][10][10][10][10][10][10]#0##1##2##3##4##5##6##7##8##9#
    wait end

### 对于早期go版本的解释： ###

1.  runtime.GOMAXPROCS(1) 规定了只能使用一个操作系统线程
2.  协程都被放入一个先入先出的队列中。
3.  main线程阻塞：wg.Wait()
4.  协程开始执行：执行顺序 同 入队顺序  
    Q：为什么输出的都是10.  
    A：输出10的是在第一个for循环中的，i在执行到wg.Wait()的时候就是10

### 对于现在版本的解释 ###

1.  存放协程的地方除了上述的队列，还有一个变量：\_p\_.runnext
2.  协程不再直接入队，而是先放入这个变量。（如果同时只有不超过一个子协程，那么队列永远为空）
3.  如果有两个子协程，A B

第一步：A协程创建：_p_.runnext=A      （此时还未执行到B协程创建） 
    第二步：B协程创建：_p_.runnext中的内容加入队列，_p_.runnext=B。

1.  同理：当有20个协程，\_p\_.runnext是最近创建的协程，其他协程都放在先进先出的队列中。  
    参考：https://blog.csdn.net/zhangdell/article/details/116979998  
    参考：https://studygolang.com/articles/11003（golang面试题）