go 协程和协程通信

Posted 2021-07-15 qianbo_insist

1、go channel

channels 是 go 协程routines之间通信的方式，更为安全，为什么这么说，他可以理解为管道， 虽然任何语言可以使用共享变量的方式， 但是更加推荐使用channel，说到管道，读者可以理解一下大学里面学的操作系统，无论linux和windows都有进程通信管道的方法。
使用 go func() 来启动协程，所以go语言在这方面比c++和java有更多的优势。

c := make(chan int)

可以使用make 来生成线程间或协程间的通道

2、协程

协程方式是充分利用线程的方式之一，openMP是充分利用多核的优势。在go里面，可以使用

runtime.GOMAXPROCS(3)

来指定协程的启动数目，我们不能在语言层面指定调度，这个是底层调度。

3、案例

package main

import (
    "runtime"
    "fmt"
	"time"
)
func main(){
	runtime.GOMAXPROCS(3)
	 c := make(chan int)
	 go sayT1(c)
	 time.Sleep(time.Second)
	 c<-1
	 c<-2

	fmt.Print(runtime.NumCPU(),"\\n")
	fmt.Println(runtime.NumGoroutine())
    var str string

    fmt.Scan(&str)
}
func sayT1(c chan int){
   fmt.Println(<- c)
   fmt.Println(<- c)
    for i:= 0; i < 10; i++{
        fmt.Println("thread run 1")
        runtime.Gosched()
    }
}

上面一段代码启动了一个sayT1()的协程，在程序开头指定了用3个协程，

runtime.NumCPU()
得到系统所包含的cpu个数，注意是逻辑cpu。

c<-1
c<-2
表明向通道输入2个int型数据，分别是1和2，系统等待一秒。
可以看出在协程中阻塞等待了这两个数据，看打印：

所以这里说这样传数据是安全的，事实上我们可以先执行其他，最后再获取数据，也是没有问题的。