channel是golang语言级别提供的协程(goroutine)之间的通信方式。
成都创新互联专注于龙亭企业网站建设,成都响应式网站建设,商城系统网站开发。龙亭网站建设公司,为龙亭等地区提供建站服务。全流程按需网站开发,专业设计,全程项目跟踪,成都创新互联专业和态度为您提供的服务
goroutine运行在相同的地址空间,因此访问共享内存必须做好同步。那么goroutine之间如何进行数据的通信呢,Go提供了一个很好的通信机制channel。channel可以与Unix shell 中的双向管道做类比:可以通过它发送或者接收值。这些值只能是特定的类型:channel类型。定义一个channel时,也需要声明发送到channel的值的类型。
var chanName chan ElementType
var ch chan int
使用make,可以指定channel容量
ch = make(chan int)
channel通过操作符<-来接收和发送数据
默认情况下,channel接收和发送数据都是阻塞的,除非另一端已经准备好,这样就使得Goroutines同步变的更加的简单,而不需要显式的lock。所谓阻塞,也就是如果读取(value := <-ch)它将会被阻塞,直到有数据接收。其次,任何发送(ch<-5)将会被阻塞,直到数据被读出。无缓冲channel是在多个goroutine之间同步很棒的工具。
ch <- v // 发送v的值到channel ch-> 写数据
v := <- ch // 从ch中接收数据,并赋值给v ->读数据
package main
import (
"fmt"
"strconv"
)
//定义一个加法函数,传入channel类型,每计算一次,quit加1
func Add(x, y int, quit chan int) {
z := x + y
fmt.Println(z)
//写数据
quit <- 1
}
//接受数据,并赋值给我
func Read(ch chan int) {
value := <- ch
fmt.Println("value" + strconv.Itoa(value))
}
func Write(ch chan int) {
//ch <- 10
}
func main() {
//定义一个channel类型切片数组
chs := make([]chan int, 10)
//循环执行加法函数
for i := 0; i < 10; i++ {
//拿取一个channel
chs[i] = make(chan int)
//执行goroutine和发送一个channel类型数据
go Add(i, i, chs[i])
}
for _, v := range chs {
//接口channel类型数据
<- v
}
}
创新互联www.cdcxhl.cn,专业提供香港、美国云服务器,动态BGP最优骨干路由自动选择,持续稳定高效的网络助力业务部署。公司持有工信部办法的idc、isp许可证, 机房独有T级流量清洗系统配攻击溯源,准确进行流量调度,确保服务器高可用性。佳节活动现已开启,新人活动云服务器买多久送多久。