您诸位好啊,我是无尘,今天开始我们进入Go语言并发阶段,说到并发,先简单介绍下几个概念:进程、线程、携程,并发、并行。
进程就是一个应用程序的工作空间,比如你打开的QQ,微信,工作空间包含了该程序运行所需的所有资源。而线程是进程中的执行单位,一个进程最少有一个线程。
协程是一种用户态的轻量级线程,线程是CPU来调度,而协程的调度完全是由用户来控制的。
Go中没有线程的概念,只有协程(goroutine),协程相比线程更加轻量,上下文切换更快。Goroutine由 Go 自己来调度,我们只管启用。
goroutine 通过 「go」 关键字来启动,非常简单,go 关键字后面加一个方法或函数 go function()
package main
import (
"fmt"
"time"
)
func main (){
go fmt.Println("微客鸟窝")
fmt.Println("我是无尘啊")
time.Sleep(time.Second) //等待一秒,使goroutine 执行完毕
}
运行结果:
我是无尘啊
微客鸟窝
channel(通道) 是用来解决多个 goroutine 之间通信问题的。
❝在 Go 语言中,提倡通过通信来共享内存,而不是通过共享内存来通信,其实就是提倡通过 channel 发送接收消息的方式进行数据传递,而不是通过修改同一个变量。所以在数据流动、传递的场景中要优先使用 channel,它是并发安全的,性能也不错。 ❞
ch := make(chan string)
chan 只有发送和接收两种操作:
示例:
package main
import (
"fmt"
)
func main() {
ch := make(chan string)
go func(){
fmt.Println("微客鸟窝")
ch <- "执行完毕"
}()
fmt.Println("我是无尘啊")
value := <-ch
fmt.Println("获取的chan的值为:",value)
}
运行结果
我是无尘啊
微客鸟窝
获取的chan的值为: 执行完毕
❝有了 chan 后,我们可以不使用 Sleep 来等 goroutine执行完了,因为接收操作(
value := <-ch
)会阻塞等待,直到它获取到值为止。 ❞
上面的操作就是一个无缓冲 channel,通道的容量是0,它不能存储数据,只是起到了传输的作用,所以无缓冲 channel 的发送和接收操作是同时进行的
在声明的时候,我们可以传入第二个参数,即「channel容量大小」,这样就是创建了一个有缓冲 channel。
//创建一个容量为3的 channel,其内部可以存放3个类型为int的元素
ch := make(chan int,3)
cap
来获取 channel 的容量,通过内置函数 len 获取 channel 中元素个数。ch := make(chan int,3)
ch <- 1
ch <- 2
fmt.Println("容量为",cap(ch),"元素个数为:",len(ch))
//打印结果:容量为 3 元素个数为:2
使用内置函数 close :close(ch)
只能发送或者只能接收的 channel 为单向 channel。
只需要在基础声明中增加操作符即可:
send := make(ch<- int) //只能发送数据给channel
receive := make(<-ch int) //只能从channel中接收数据
示例:
package main
import (
"fmt"
)
//只能发送通道
func send(s chan<- string){
s <- "微客鸟窝"
}
//只能接收通道
func receive(r <-chan string){
str := <-r
fmt.Println("str:",str)
}
func main() {
//创建一个双向通道
ch := make(chan string)
go send(ch)
receive(ch)
}
//运行结果: str: 微客鸟窝
select 可以实现多路复用,即同时监听多个 channel。
示例:
package main
import (
"fmt"
)
func main() {
ch := make(chan int, 1)
for i := 0; i < 10; i++ {
select {
case x := <-ch:
fmt.Println(x)
case ch <- i:
fmt.Println("--", i)
}
}
}
运行结果:
-- 0
0
-- 2
2
-- 4
4
-- 6
6
-- 8
8
此处留作思考题,为何会这样输出呢?