Channel
- Channel是goroutine沟通的桥梁,大都是阻塞同步的
- 通过make创建,close关闭(当程序简单时,回自动关闭)
package main
import (
"fmt"
)
func main() { //主程序
c := make(chan bool) //初始化一个chan类型
go func() { //子程序
fmt.Println("123...") //执行主程序
c <- true //通过<-存入bool类型到chan中
}()
fmt.Println(1) //程序执行步骤:1st
read_chan := <-c //<-c 从chan中读取bool,程序执行步骤:2nd
fmt.Println(read_chan) //程序执行步骤:3rd
}
/*output
1st 1
2nd 123...
3rd true
*/
注意以上程序的执行顺序(channel无缓存时):先执行读取操作c<-c
,因为channel中没有值,所以程序发生阻塞,此时执行chanel写操作
,然后再执行读操作。
package main
import (
"fmt"
)
func main() {
c := make(chan bool) //初始化一个chan类型
go func() { //go结合匿名函数,构造并发
fmt.Println("123...") //执行主程序
c <- true //通过<-存入bool类型到chan中
close(c) //关闭通道:必须明确在哪个地方关闭
}()
for v := range c { //for循环chanel
}
}
/*output
123...
true
*/
package main
import (
"fmt"
)
func main() { //主程序
c := make(chan bool,1) //初始化一个chan类型,缓存为2
go func() { //子程序
fmt.Println("123...") //执行主程序,执行步骤:2
c <- true //写操作,执行步骤:2
}()
fmt.Println(2) //执行步骤:1
fmt.Println(123,<-c) //读操作,执行步骤:2
fmt.Println(3) //执行步骤:3
}
/*output
1 2
2 123...
2 123 true
3 3
*/
设置缓存后,程序为异步,读,写操作同时完成,当读取channal中无数据时,也不会造成堵塞,因为与此同时,写操作也将发生。