1、未使用go channel
计算
安全
数据库
网络和加速
企业服务
package main
import (
"fmt"
"time"
)
func printer(s string) {
for _, v := range s {
fmt.Println(string(v))
time.Sleep(time.Millisecond * 3000)
}
}
func person() {
printer("hello")
}
func person2() {
printer("world")
}
func main() {
go person()
go person2()
for {
}
}d:\goprojects\src\day1\练习>go run main.go
h
w
e
o
l
r
l
l
o
d
exit status 22、使用channel
package main
import (
"fmt"
"time"
)
var ch = make(chan int, 1)
func printer(s string) {
for _, v := range s {
fmt.Println(string(v))
time.Sleep(time.Millisecond * 3000)
}
}
func person() {
printer("hello")
ch <- 1
}
func person2() {
<-ch
printer("world")
}
func main() {
go person()
go person2()
for {
}
}d:\goprojects\src\day1\练习>go run main.go
h
e
l
l
o
w
o
r
l
d3、小结
channel 有两端，一端写入（数据传入）ch<- ;一端读出（传出数据）;要求读写两端必须同时满足条件，才能在channel上完成数据流动，否则阻塞。
4、 关闭channel
package main
import "fmt"
func main() {
ch := make(chan int)
go func() {
for i := 0; i < 8; i++ {
ch <- i
}
close(ch)
}()
for {
if num, ok := <-ch; ok {
fmt.Println(num)
} else {
fmt.Println("channel close")
break
}
}
}d:\goprojects\src\day1\并发\exp1>go run main.go
0
1
2
3
4
5
6
7
channel close
d:\goprojects\src\day1\并发\exp1>亿速云「云服务器」，即开即用、新一代英特尔至强铂金CPU、三副本存储NVMe SSD云盘，价格低至29元/月。点击查看>>
免责声明：本站发布的内容（图片、视频和文字）以原创、转载和分享为主，文章观点不代表本网站立场，如果涉及侵权请联系站长邮箱：is@yisu.com进行举报，并提供相关证据，一经查实，将立刻删除涉嫌侵权内容。
