Go 语言学习笔记-Goroutine和channel

Goroutine

什么是 Goroutine

Goroutine 是 Go 并行设计的核心。Goroutine 说到底其实就是协程,它比线程更小,十几个 Goroutine 可能体现在地城就是五六个线程,Go 语言内部实现了这些 Goroutine 之间的内存共享。

执行 Goroutine 只需极少的栈内存(大概是 4~5KB),会根据相应的数据伸缩。也正因为如此,可同时运行成千上万个并发任务。Goroutine 比 thread 更易用、更高效、更轻便。

Goroutine 的创建

只需要在函数调用语句前添加 go 关键字,就可创建并发执行单元。开发人员无需了解任何执行细节,调度器会自动将其安排到合适的系统线程上执行。

Goroutine 的特征

主 go 程结束,子 go 程随之退出

示例

package main

import (
    "fmt"
    "time"
)

func sing() {
    for i := 0; i < 50; i++ {
        fmt.Println("----我正在唱歌----")
        time.Sleep(100 * time.Millisecond)
    }
}

func dance() {
    for i := 0; i < 50; i++ {
        fmt.Println("----我正在跳舞----")
        time.Sleep(100 * time.Millisecond)
    }
}

func main() {
  // 子 go 程
    go sing()
    go dance()

  // 主 go程循环打印
    for {
        ;
    }
}

程序运行结果:

go程示例.png

runtime 包

  • Gosched

    runtime.Gosched() 用于让出 CPU 时间片,让出当前 goroutine 的执行权限,调度器安排其他等待的任务运行,并在下次再获得 CPU 时间轮片的时候,从该处让 CPU 的位置恢复执行。 ---时间片轮传调度算法

  • Goexit

    调用 runtime.Goexit() 将立即终止当前 goroutine 执行,调度器确保所有已注册 defer 延迟调用被执行。

    • return:返回当前函数调用到调用者那里去。return 之前的 defer 注册生效。
    • Goexit():结束调用该函数的当前 go 程。Goexit() 之前注册的 defer 都生效。
  • GOAMAXPROCS

    调用 runtime.GOMAXPROCS(),用来设置可以并行计算的 CPU 核数的最大值,返回返回之前的值。首次调用返回默认值。

  • 补充

    • 每当有一个进程启动时,系统会自动打开三个文件:标准输入、标准输出、标准错误。 ---对应三个文件:stdin、stdout、stderr。

    • 当进程运行结束,操作系统自动关闭三个文件。

channel

  • channel 是 Go 语言中的一个 核心类型,可以把它看成管道(通道 FIFO)。并发核心单元通过它就可以发送或者接收数据进行通讯。

  • channel 是一个数据类型,只要用来解决协程的同步问题以及协程之间数据共享(数据传递)的问题。

  • goroutine 运行在相同的地址空间,因此访问共享内存必须做好同步。goroutine 奉行通过通信来共享内存,而不是共享内存来通信

  • 引用类型 channel 可用于多个 goroutine 通讯。其内部实现了同步,确保并发安全。

goroutine.jpg

定义 channel 变量

chan 是创建 channel 所需使用的关键字。Type 代表指定 channel 手法数据的类型。

make(chan Type)     // 等价于 make(chan Type, 0)
make(chan Type, capacity)

和 map 类似,channel 也是一个对应 make 创建的底层数据结构的引用

和其它的引用类型一样,channel 的零值也是 nil。

赋值 channel 或者用于函数参数传递,都是使用的 channel 的引用。

当阐述 capacity = 0 时,channel 是无缓冲阻塞读写的;当 capacity > 0 时,channel 有缓冲、是非阻塞的,直到写满 capacity 个元素才阻塞写入。

channel 非常像生活中的管道,一边可以存放东西,另一边可以取出东西。channel 通过操作符 <- 来接收和发送数据:

channel := make(chan int)
channel <- value        // 写端(传入端):发送 value 到 channel
x := <- channel         // 读端(传出端):从 channel 中接收数据,并赋值给 x
x, ok := <- channel     // 功能同上,同时检查通道是否已关闭或者是否为空

默认情况下,channel 接收和发送数据都是阻塞的,除非另一端已经准备好,这样就使得 goroutine 同步变得更加简单,而不需要显示 lock

无缓冲 channel

make(chan Type)     // 等价于 make(chan Type, 0)

无缓冲的通道(unbuffered channel):是指在接收前没有能力保存任何值的通道。

如果没有指定缓冲区容量,那么该通道就是同步的,因此会阻塞到发送者准备好发送和接收者准备好接收,才解除阻塞。

无缓冲的goroutine.png

有缓冲 channel

make(chan Type, capacity)       // capacity > 0

有缓冲的通道(buffered channel)是一种在被接收前能存储一个或者多个数据值的通道。

  • 这种类型的通道并不强制要求 goroutine 之间必须同时完成发送和接收。通道会阻塞发送和接收动作的条件也不同。
    • 只要通道中没有要接收的值时,接收动作才会阻塞。
    • 只要通道没有可用缓冲区容纳被发送的值时,发送动作才会阻塞。

如果给定一个缓冲区容量,通道就是异步的。只要缓冲区有未使用空间用于发送数据,或还包含可以接收的数据,那么其通信就会无阻塞的进行。

有缓冲的goroutine.png

有缓冲和无缓冲 channel 的区别

  • 无缓冲的通道保证进行发送和接收的 goroutine 会在同一时间进行数据交换;有缓冲的通道没有这种保证。

关闭 channel

如果发送者知道,没有更多的值要发送到 channel 的话,那么有必要让接收者也能及时知道没有多余的值可接受,因此接收者可以停止不必要的接收等待。可以通过内置的 close() 函数来关闭 channel。

package main

import (
    "fmt"
)

func main() {
    c := make(chan int)

    go func() {
        for i := 0; i < 5; i++ {
            c <- i
        }
        //把 close(c) 注释掉,程序会一直阻塞在 if data, ok := <-c; ok 那一行
        close(c)
    }()

    for {
        //ok为true说明channel没有关闭,为false说明管道已经关闭
        if data, ok := <-c; ok {
            fmt.Println(data)
        } else {
            break
        }
        }
        
        // 可以使用 range 来迭代不断操作 channel
        // for data := range c {
    //     fmt.Println(data)
    // }

    fmt.Println("Finished")
}

注意

  • channel 不像文件一样需要经常去关闭,只有当你确实没有任何发送数据了,或者你想显示的结束 range 循环之类的,才去关闭 channel
  • 关闭 channel 后,无法向 channel 再发送数据(引发 panic 错误后导致接收立即返回零值)
  • 关闭 channel 后,可以继续从 channel 接收数据
  • 对于 nil channel,无论收发都会被阻塞。

单向 channel 及应用

默认情况下,通道 channel 是双向的。也就是,既可以往里面发送数据,也可以从里面接收数据。

但是,我们经常见一个通道作为参数进行传递而只希望对方是单向使用的,要么只让它发送数据,要么只让它接收数据,这时候我们可以指定通道的方向

channel.png
var ch1 chan int    // ch1 是一个正常的 channel,是双向的
var ch2 chan<- float64  // ch2 是单向的 channel,只用于写 float64 数据
var ch3 <-chan int      // ch3 是单向 channel,只用于读 int 数据
  • chan <-:表示数据进入管道,要把数据写进管道,对于调用者就是输出。
  • <- chan:表示数据从管道出来,对于调用者就是得到管道的数据,就是输入。

可以将 channel 隐式转换为单向队列,只收或者只发,不能将单向 channel 转换为普通 channel:

ch := make(chan int, 3)
var send chan<- int = ch    // send-only
var recv <-chan int = ch    // receive-only
send <- 1
//<-send //invalid operation: <-send (receive from send-only type chan<- int)
<-recv
//recv <- 2 //invalid operation: recv <- 2 (send to receive-only type <-chan int)

//不能将单向 channel 转换为普通 channel
d1 := (chan int)(send) //cannot convert send (type chan<- int) to type chan int
d2 := (chan int)(recv) //cannot convert recv (type <-chan int) to type chan int
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 212,657评论 6 492
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 90,662评论 3 385
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 158,143评论 0 348
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 56,732评论 1 284
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 65,837评论 6 386
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 50,036评论 1 291
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 39,126评论 3 410
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 37,868评论 0 268
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 44,315评论 1 303
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 36,641评论 2 327
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 38,773评论 1 341
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 34,470评论 4 333
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 40,126评论 3 317
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 30,859评论 0 21
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,095评论 1 267
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 46,584评论 2 362
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 43,676评论 2 351

推荐阅读更多精彩内容