go并发编程36——管道（channel）

/*
channel实现同步
*/
package mainimport ("fmt""time"
)//创建一个管道
var ch &＃61; make(chan int)func Print(s string) {for _, data :&＃61; range s {fmt.Printf("%c", data)time.Sleep(time.Second)}fmt.Println("\n")
}//目标:先打印hello 再打印go
func Person1() {Print("hello")ch <- 1 //给管道写数据(发送) "1"只是用于举例
}func Person2() {<-ch //从管道取数据(接收)&＃xff0c;如果通道没有数据&＃xff0c;会阻塞Print("go")
}func main() {//新建两个协程go Person1()go Person2()for {}
}

通过channel实现同步和数据交互

package mainimport ("fmt""time"
)func main() {//创建管道ch :&＃61; make(chan string)defer fmt.Println("主协程结束")go func() {defer fmt.Println("子协程调用完毕")for i :&＃61; 0; i <2; i&＃43;&＃43; {fmt.Println("i &＃61; ", i)time.Sleep(time.Second)}ch <- "q"}()str :&＃61; <-ch //没有数据前&＃xff0c;会阻塞fmt.Println("str &＃61; ", str)
}

无缓冲的channel

package mainimport ("fmt""time"
)func main() {//创建无缓冲的通道ch :&＃61; make(chan int, 0)//len(ch)缓冲区剩余数据个数&＃xff0c;cap(ch)缓冲区大小fmt.Printf("len(ch) &＃61; %d, cap(ch) &＃61; %d\n", len(ch), cap(ch))go func() {for i :&＃61; 0; i <3; i&＃43;&＃43; {fmt.Println("子协程:i &＃61; ", i)ch <- i //ch中的数据没有被读出去之前会阻塞在这}}()time.Sleep(2 * time.Second)for i :&＃61; 0; i <3; i&＃43;&＃43; {num :&＃61; <-chfmt.Println("num &＃61; ", num)}
}

有缓冲的channel

/*
格式: make(chan type, capacity)
如果给定缓冲区容量&＃xff0c;通道是异步的。只要缓冲区有未使用的空间用于发送数据&＃xff0c;或者还包括
可以接收的数据&＃xff0c;那么其通信就会无阻塞的进行
*/
package mainimport ("fmt""time"
)func main() {//创建有缓冲的通道ch :&＃61; make(chan int, 3)fmt.Printf("len(ch) &＃61; %d, cap(ch) &＃61; %d\n", len(ch), cap(ch)) //len(ch):0 cap(ch):3go func() {for i :&＃61; 0; i <10; i&＃43;&＃43; {ch <- i //ch满之后不能再写fmt.Printf("子协程[%d]:len(ch) &＃61; %d, cap(ch) &＃61; %d\n", i, len(ch), cap(ch))}}()time.Sleep(2 * time.Second)for i :&＃61; 0; i <10; i&＃43;&＃43; {num :&＃61; <-chfmt.Println("num &＃61; ", num)}
}

关闭channel

/*
1. 关闭channel后&＃xff0c;无法向channel再发送数据(引发panic错误后导致接收立即返回0)
2. 关闭channel后&＃xff0c;可以继续向channel接收数据
3. 对于nil channel,无论收发都会别阻塞
*/
package mainimport ("fmt"
)func main() {//创建无缓冲的通道ch :&＃61; make(chan int, 0)go func() {for i :&＃61; 0; i <5; i&＃43;&＃43; {ch <- i //写数据}//不需要再写数据时&＃xff0c;关闭channelclose(ch) //屏蔽此行会死锁 无法跳出下面的死循环//ch <- 1 //关闭channel后无法再发送数据}()//方法1/*for {//如果ok为true,说明ch没有关闭num, ok :&＃61; <-ch //读数据if ok &＃61;&＃61; true {fmt.Println("num &＃61; ", num)} else {break}}*///方法2for num :&＃61; range ch {fmt.Println("num &＃61; ", num)}
}

单向channel的特性

package main//import "fmt"func main() {//创建一个channelch :&＃61; make(chan int)//双向channel可以隐式转换为单向channelvar wCh chan<- int &＃61; ch //只写wCh <- 12//<-wChch <- 12var rCh <-chan int &＃61; ch //只读<-rCh//rCh <- 11//单向是无法转换为双向的//var ch2 chan int &＃61; rCh
}

单向channel的应用

package mainimport "fmt"//此通道只能写不能读
func Producer(wCh chan<- int) {for i :&＃61; 0; i <10; i&＃43;&＃43; {wCh <- i * i}close(wCh)
}//只能读 不能写
func Consumer(rCh <-chan int) {for num :&＃61; range rCh { //rCh没有数据会阻塞fmt.Println("num &＃61; ", num)}
}func main() {//创建一个双向通道ch :&＃61; make(chan int)//生产者go Producer(ch) //channel传参是引用传递//消费者Consumer(ch)
}

timer

package mainimport ("fmt""time"
)func main() {//创建一个定时器&＃xff0c;设置时间为2s&＃xff0c;2s后&＃xff0c;往time通道写数据(当前时间)//时间到了 timer只会响应一次timer :&＃61; time.NewTimer(2 * time.Second)fmt.Println("当前时间:", time.Now())//2s后&＃xff0c;往timer.C写数据&＃xff0c;有数据后&＃xff0c;就可以读取t :&＃61; <-timer.C //channel没有数据前会阻塞fmt.Println("t &＃61; ", t)
}

通过timer实现延时

/*
延时的3种方式
sleep.go
*/
package mainimport ("fmt""time"
)func main() {//方式1time.Sleep(2 * time.Second)//方式2 定时2s 阻塞2s 2s后会产生一个事件 往channel写数据<-time.After(2 * time.Second)//方式3//延时2s后打印一句话timer :&＃61; time.NewTimer(2 * time.Second)<-timer.C //时间未到会阻塞fmt.Println("时间到")}

定时器停止和重置

package mainimport ("fmt""time"
)func main() {timer :&＃61; time.NewTimer(3 * time.Second)b :&＃61; timer.Reset(1 * time.Second) //定时器重置fmt.Println("b &＃61; ", b)<-timer.Cfmt.Println("时间到") //3s后打印
}func main1() {timer :&＃61; time.NewTimer(3 * time.Second)go func() { //创建一个匿名函数作为子协程<-timer.C //3s过后停止阻塞 执行下面的打印fmt.Println("定时器时间到,子协程打印")}()timer.Stop() //停止定时器for { //主协程死循环}
}

Ticker

package mainimport ("fmt""time"
)func main() {ticker :&＃61; time.NewTicker(1 * time.Second)i :&＃61; 0for {<-ticker.Ci&＃43;&＃43;fmt.Println("i &＃61; ", i)if i &＃61;&＃61; 5 {ticker.Stop()break}}
}