Do not communicate by sharing memory; instead, share memory by communicating.
nodejs的异步io模型,python的协程和多进程,java的multi-thread,说到底,这些模型都是为了实现程序的并行。我相信,大家在学习golang前,肯定都做了一些调研,也肯定看到了很多人在称赞golang的时候提到了golang在并行上的优点。
什么是并发和并行
并发就是,你有二十个女朋友,然后他们同时在和你聊微信。而并行就是,你实在聊不过来了,于是你雇了5个人帮你同时和你的女朋友们聊天。
goroutine
一开始你只找到了一个好朋友肯帮你。你的朋友照着模板敲一些情话,你负责填入女孩的名字。
func sayName() {
girls := []string { "amy","rose","lily","judy","penny"}
for i := 0; i < 5; i++ {
fmt.Print(girls[i] + "\n")
runtime.Gosched()
}
}
func sayLove(){
for i := 0; i<5; i++ {
fmt.Print("I love you,")
runtime.Gosched()
}
}
func main() {
go sayName()
sayLove()
}
//output:
//I love you,amy
//I love you,rose
//I love you,lily
//I love you,judy
//I love you,penny
这样你就同时和5个女孩聊上了,这里,你的哥们占据着主线程,不停的说"Ilove you",而你则占据着一个goroutine(可以理解为线程),不停的输入女孩的名字。这里的runtime.Gosched()类似于python里的yeild,用于交出cpu,等之后再回来计算,就是说,你的哥们每次敲完"i love you",就把键盘交给你,然后你开始敲女孩的名字,等你敲完,你再把键盘交给你哥们。看上去天衣无缝吧,但是这么搞很危险啊。万一你的哥们动作慢了几拍,你却以为他已经敲了,又接过键盘(cpu),连打了几个女孩的名字,你这是要扑街啊。
channel
为了安全起见,还是多找几个朋友(goroutine)吧,没来一个女朋友的聊天,你就找一个goroutine盯着,然后通过一个管道告诉你应该怎么回答。
func sayName(s string, c chan string) {
c <- "I love you," + s //发送值
}
func main() {
girls := []string { "amy","rose","lily","judy","penny"}
c := make(chan string)
for _,g := range girls{
go sayName(g, c)
}
x1,x2,x3,x4,x5 := <- c, <- c, <- c, <- c, <- c //接收值
fmt.Println(x1)
fmt.Println(x2)
fmt.Println(x3)
fmt.Println(x4)
fmt.Println(x5)
}
这里我们使用了channel,这是go中用来在goroutine之间进行数据通信的一种通信机制。说白了,我们可以用它来发送和接受值这些值。我们使用make 创建channel,并声明发送到channel的值的类型。另外需要注意的是,channel的收发默认是阻塞的,也就是说在我们接收值得时候,如果channel还没有返回,程序会阻塞在这里。
select
等等,有细心的小伙伴发现了问题,这小子胆儿够肥啊,不怕把发给amy的消息发给lily啊。你用一个channel不是等于群聊了么(虽然这里的channel并不是用来在和女朋友之间通信的)。okok,为了安全,给每个女朋友建一个channel。
func sayName(amy,lily,judy chan int) {
for {
//不停监听每个channel的消息,对不同的女孩说不同的话
//select用起来的感觉和switch差不多
select {
case <- amy :
fmt.Println("I love you amy")
case <- lily :
fmt.Println("I love you lily")
case <- judy :
fmt.Println("I love you judy")
}
}
}
func main(){
//给每个女孩都建一个channel
amy := make(chan int)
lily := make(chan int)
judy := make(chan int)
//跑一个goroutine专门用来监听每个女孩的channel
go sayName(amy, lily, judy)
amy <- 0
lily <- 0
judy <- 0
}
写了这么多,终于到了点明主旨的时候了,愿世间没有渣男。Peace!