channel(一)
channel用于goroutines之间的通信,让它们之间可以进行数据交换。像管道一样,一个goroutine_A向channel_A中放数据,另一个goroutine_B从channel_A取数据
channel 基本语法
// 因为channel是指针类型的数据类型,所以通过make来分配内存
// 使用make声明一个channel,里面可以存放string类型的数据
channel := make(chan string)
// 将tmp送到channel中
channel <- tmp
// 从channel中接受数据给tmp
tmp := <- channel
// 从channel中接受数据给tmp,如果没有接受到则ok值为false
tmp,ok := <- channel
// 关闭通道channel
close(channel)
无缓冲的通道
没有缓冲的通道,如果routine A向通道中发送了一个数据,那么必须等到这个数据被其他routine 取出之后,才能继续往通道里发送,严格遵循”一进一出“原则,这也就要求两个routine 在同时对同一个通道进行写操作和取操作文章来源:https://www.toymoban.com/news/detail-434238.html
- sender端向channel中send一个数据,然后阻塞,直到receiver端将此数据receive
- receiver端一直阻塞,直到sender端向channel发送了一个数据
// 两个routine分别对一个通道进行取放操作,并且对里面的数据+1,到2000截至
// 严格遵循“一进一出”
func Routine01(wg *sync.WaitGroup, count chan int) {
defer wg.Done()
for {
// 从通道中拿取数据
res, ok := <-count
if !ok {
// 说明通道中已经没有数据,或者已被关闭
fmt.Println("finish!")
break
}
fmt.Println(res)
if res == 2000 {
close(count)
break
}
count <- res + 1
}
}
func main() {
var wg sync.WaitGroup
// 新建一个无缓冲的通道count
count := make(chan int)
wg.Add(2)
// 创建两个协程
for i := 0; i < 2; i++ {
go Routine01(&wg, count)
}
// 给管道里送一个数据,来开始操作
count <- 1
wg.Wait()
}
有缓冲的通道
有缓冲的通道,可以控制里面的缓冲区大小,可以借助通道实现异步的取放操作文章来源地址https://www.toymoban.com/news/detail-434238.html
- 容量:表示buffered channel最多可以缓冲多少个数据
- 长度:表示buffered channel当前已缓冲多少个数据
- 创建buffered channel的方式为
make(chan TYPE,CAP)
// 新建Routine来模拟机器人工作
func Routine02(wg *sync.WaitGroup, count chan string) {
defer wg.Done()
for {
// 从通道中分配工作
tmp, ok := <-count
if !ok {
// 代表通道已经空了,或者已被关闭
fmt.Println("No task else!")
break
}
fmt.Println(tmp + " start!")
time.Sleep(200 * time.Millisecond)
fmt.Println(tmp + " done!")
}
}
func main() {
var wg sync.WaitGroup
// 新建一个缓冲区大小为5的通道,来管理工作
count := make(chan string, 5)
wg.Add(2)
fmt.Println("Work start!")
// 往缓冲区中放一系列待完成的工作
for i := 0; i < 5; i++ {
tmp := fmt.Sprintf("Task %d", i)
count <- tmp
fmt.Println(tmp + " in!")
}
for i := 0; i < 2; i++ {
go functions.Routine(&wg, count)
}
// 关闭通道
close(count)
wg.Wait()
}
到了这里,关于Go语言入门14(channel通道01)的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!