Golang并发编程进程通信channel了解及简单使用

时间:2024-09-01 22:38:08

概念及作用

channel是一个数据类型,用于实现同步,用于两个协程之间交换数据。goroutine奉行通过通信来共享内存,而不是共享内存来通信。
引用类型channel是CSP模式的具体实现,用于多个goroutine通讯。其内部实现了同步,确保并发安全。

创建及使用
每个channel在创建的时候必须指定一个类型,指定的类型是任意的。

ch := make(chan int)   //使用内置的make函数,可以创建一个channel类型
// 发送数据到channel
ch <-
// 从channel接受数据
x := <- ch

案例举例(一)

①创建channel前

package main

import (
"fmt"
"time"
) //定义一个打印机,参数为字符串,按每个字符打印
//打印机属于公共资源
func Printer(str string) {
for _, data := range str {
fmt.Printf("%c", data)
time.Sleep(time.Second)
}
fmt.Printf("\n")
} func person1() {
Printer("hello")
} func person2() {
Printer("world")
} func main() {
//新建2个协程,代表2个人,2个人同时使用打印机
go person1()
go person2() //特地不让主协程结束,死循环
for { }
}
//结果
hwoerllldo //交叉执行

②创建channel后(注意channel变量和调用的先后顺序)

package main

import (
"fmt"
"time"
) //全局变量,创建一个channel
var ch = make(chan int) //定义一个打印机,参数为字符串,按每个字符打印
//打印机属于公共资源
func Printer(str string) {
for _, data := range str {
fmt.Printf("%c", data)
time.Sleep(time.Second)
}
fmt.Printf("\n")
} //person1执行完后,才能到person2执行
func person1() {
Printer("hello")
ch <- //给管道写数据,发送
} func person2() {
<-ch //从管道取数据,接收,如果通道没有数据他就会阻塞
Printer("world")
} func main() {
//新建2个协程,代表2个人,2个人同时使用打印机
go person1()
go person2() //特地不让主协程结束,死循环
for { }
}
hello
world

案例举例(二)

package main

import (
"fmt"
) func main() {
ch := make(chan string)
go func() {
fmt.Println("aaaaaaaaaa")
str := <-ch // 在执行到这一步的时候main goroutine才会停止阻塞
fmt.Println("取出channel的数据" + str)
}()
fmt.Println("bbbbbbbbbb")
ch <- "hello" // 如果没有其他goroutine来取走这个数据,main goroutine挂起,直到其它gorouteine把数据拿走(这里会暂时阻塞)
fmt.Println("cccccccccc")
}
bbbbbbbbbb
aaaaaaaaaa
取出channel的数据hello
cccccccccc