Go语言goroutine和通道学习

Go语言里的并发指的是能让某个函数独立于其他函数运行的能力。当一个函数创建为goroutine时,Go会将其视为一个独立的工作单位。这个单元会被调度到可用的逻辑处理器上执行。

Go语言运行时的调度器是一个复杂的软件,能管理被创建的所有goroutine并为其分配执行时间。这个调度器在操作系统之上,将操作系统的线程与语言运行时的逻辑处理器绑定,并在逻辑处理器上运行goroutine。调度器在任何给定的时间,都会全面控制那个goroutine要在那个逻辑处理器上运行。

一、协程

执行体是也抽象的概念,在操作系统层面有多个概念与之对应,比如操作系统自己掌握的进程、进程内的线程以及进程内的协程。与传统的系统级别的线程与进程相比,协程的最大优势在于其”轻量级”,可以轻松创建百万个而不会导致资源枯竭,远远高于线程进程数量。

Go语言在语言级别支持轻量级线程,叫goroutine。Go语言标准库提供的所有系统调用操作,都会让出CPU给其他goroutine,轻量级线程的切换管理不依赖系统的线程和进程,也不依赖CPU的核心数量。

如果创建一个goroutine并准备运行,这个goroutine会被放到调度器的全局运行队列中。之后,调度器就将这些队列中的goroutine分配给一个逻辑处理器,并放到这个逻辑处理器对应的本地运行队列中。本地运行队列中的goroutine会一直等待知道自己被分配的逻辑处理器执行。

Go语言运行时会把goroutine调度到逻辑处理器上运行。这个逻辑处理器绑定到唯一的操作系统线程。当goroutine可以运行的时候,会被放入逻辑处理器的执行队列中。

当goroutine执行了一个阻塞的系统调用时,调度器会被这个线程与处理器分离,并创建一个新的线程来运行这个处理器提供的服务。

二、并发与并行

并行是让不同的代码片段同时在不同的物理处理器上执行。并行的关键是同时做很多事情,二并发是指同时管理很多事情,这些事情可能只做了一般被暂停去做别的事情。很多情况下,并发的效果比并行好,因为操作系统和硬件的总资源一般很少,但能支持系统同时做很多事情。

如果希望goroutine并行,必须使用多于一个逻辑处理器。当有多个逻辑处理器时,调度器会将goroutine平等分配到每个逻辑处理器上。这会让goroutine在不同的线程上运行。要想实现并行的效果,用户需要让自己的程序运行在多个物理处理器的机器上。

四、goroutine

funcmain(){

runtime.GOMAXPROCS(1)

varwgsync.WaitGroup

wg.Add(2)

fmt.Println("start goroutes")

go func() {

deferwg.Done()

forcount:=;count

forchar:='a';char

fmt.Printf("%c",char)

}

}

}()

go func() {

deferwg.Done()

forcount:=;count

forchar:='A';char

fmt.Printf("%c",char)

}

}

}()

wg.Wait()

fmt.Println("\nProgram exit")

}

程序的输出结构为:

start goroutes

ABCDEABCDEABCDEabcdeabcdeabcde//可能先全小写字母再大写字母

Program exit

因为只有一个逻辑处理器,而且每个goroutine处理花费的时间不长,所有每次先处理完一个goroutine再处理另外一个。

基于调度器的内部算法,一个正在运行的goroutine在结束之前,可以被停止并重新调度。调度器这样做的目的是防止某个goroutine占用时间过长,调度器会停止当前运行的goroutine,并给其他可运行的goroutine运行的机会。

在使用goroutine编程的时候可能会遇到goroutine还没开始执行主程序已经退出的情况,因此使用WaitGroup来进行同步,保证goroutine先执行完成在主程序退出。WaitGroup是一个计数信号量,可以用来记录并维护运行的goroutine。如果WaitGroup的值大于0,Wait方法就会阻塞。关键字defer会修改函数的调用时机,在正在执行的函数返回时才能真正调用defer声明的函数。

使用WaitGroup时,建议在goroutine外使用WaitGroup.Add,以免Add未执行,Wait已经退出。

程序中调用了runtime包的GOMAXPROCS函数。这个函数允许程序更改调度器可以使用的逻辑处理器的数量。函数中传参1,是通知调度器只能为该程序用一个逻辑处理器。可以根据计算机的CPU个数指定逻辑处理器的个数runtime.GOMAXPROCES(runtime.NumCPU)。

五、通道

Go语言天然支持高并发很重要的原因是可以支持goroutine与通道类型,通过通道,发送和接受需要的资源,在goroutine之间做同步。

当一个资源需要在goroutine之间共享时,通道在goroutine之间架起了一个管道,并提供了确保同步交换数据的机制,声明通道时,需要指定被共享资源的数据类型。可以通过通道共享内置类型、命名类型、结构类型和引用类型的值和指针。

在Go语言中需要使用内置函数make来创建一个通道:

strchan1:=make(chanstring)

strchan2:=make(chanstring,10)

使用内置函数make创建了两个通道,一个无缓冲区的通道,一个有缓冲区的通道,make的第一个参数需要关键字chan,后面跟着允许通道交换的数据的类型。如果创建一个有缓冲区的通道,之后需要在第二个参数指定这个缓冲区的大小。

//放入一个字符串到通道

strchan2

//从通道接受一个字符串

value:=

无缓冲区的通道要求发送goroutine和接受goroutine同时准备好,才能完成发送和接受操作。如果两个goroutine没有同时准备好,通道会导致先执行发送或接受的goroutine阻塞等待。这种通道的发送和接受的交互行为本身就是同步的。

有缓冲区的通道是一种在被接受前能存储一个或者多个值的通道。这种类型的通道并不会强制要求goroutine之间必须同时完成发送和接受。通道会阻塞发送和接受动作的条件也会不同。只有在通道中没有要接受的值时,接受动作才会阻塞。只有通道没有可缓冲去容纳被发送的值时,发送动作才会被阻塞。无缓冲区的通道保证发送和接受的goroutine会在同一时间进行数据交换,有缓冲区没有这个保证。

部分人可能认为无缓冲区就是缓冲区为1,其实有很大的区别。

c1:=make(chanint)无缓冲

c2:=make(chanint,1)有缓冲

c1

无缓冲的 不仅仅是 向 c1 通道放 1 而是 一直要有别的携程

而 c2

由于通道变量本身就是指针,可用相等操作符判断是否为同意对象或nil。

funmain(){

vara,bchan int=make(chanint),make(chanint,3)

varcchanbool

fmt.Println(a==b)

fmt.Println(c==nil)

}

false true

内置函数cap和len返回缓冲区大小和当前缓冲区数量;而对于无缓冲区的通道都返回为0,可以据此判断通道是同步还是异步。

  • 发表于:
  • 原文链接https://kuaibao.qq.com/s/20180831G1B93100?refer=cp_1026
  • 腾讯「云+社区」是腾讯内容开放平台帐号(企鹅号)传播渠道之一,根据《腾讯内容开放平台服务协议》转载发布内容。

同媒体快讯

扫码关注云+社区

领取腾讯云代金券