您好,登錄后才能下訂單哦!
// code_043_channel_unbuffered project main.go
package main
import (
"fmt"
"time"
)
func main() {
c := make(chan int, 0) //無緩沖的通道
//內(nèi)置函數(shù) len 返回未被讀取的緩沖元素數(shù)量, cap 返回緩沖區(qū)大小
fmt.Printf("len(c)=%d, cap(c)=%d\n", len(c), cap(c))
go func() {
defer fmt.Println("子協(xié)程結(jié)束")
for i := 0; i < 3; i++ {
fmt.Printf("子協(xié)程正在運行[%d]: len(c)=%d, cap(c)=%d\n", i, len(c), cap(c))
c <- i //備注:如果在上面的話, 不會執(zhí)行最后一次Printf
}
}()
time.Sleep(2 * time.Second) //延時2s
for i := 0; i < 3; i++ {
num := <-c //從c中接收數(shù)據(jù),并賦值給num
fmt.Println("num = ", num)
}
fmt.Println("main協(xié)程結(jié)束")
}
// code_044_channel_buffered project main.go
package main
import (
"fmt"
"time"
)
//有緩沖的通道(buffered channel)是一種在被接收前能存儲一個或者多個值的通道。
//只有在通道中沒有要接收的值時,接收動作才會阻塞。只有在通道沒有可用緩沖區(qū)容納被發(fā)送的值時,發(fā)送動作才會阻塞。
//有緩沖的通道和無緩沖的通道之間的不同:
//1)無緩沖的通道保證進行發(fā)送和接收的 goroutine 會在同一時間進行數(shù)據(jù)交換;
//2)有緩沖的通道沒有這種保證
func main() {
c := make(chan int, 3)
fmt.Printf("len(c)=%d, cap(c)=%d\n", len(c), cap(c))
go func() {
defer fmt.Println("子協(xié)程結(jié)束")
for i := 0; i < 3; i++ {
c <- i
fmt.Printf("子協(xié)程正在運行[%d]: len(c)=%d, cap(c)=%d\n", i, len(c), cap(c))
}
}()
time.Sleep(2 * time.Second)
for i := 0; i < 3; i++ {
num := <-c
fmt.Println("num=", num)
}
fmt.Println("main協(xié)程結(jié)束")
}
// code_045_channel_range_close project main.go
package main
import (
"fmt"
)
//注意點:
//?channel不像文件一樣需要經(jīng)常去關(guān)閉,只有當你確實沒有任何發(fā)送數(shù)據(jù)了,或者你想顯式的結(jié)束range循環(huán)之類的,才去關(guān)閉channel;
//?關(guān)閉channel后,無法向channel 再發(fā)送數(shù)據(jù)(引發(fā) panic 錯誤后導致接收立即返回零值);
//?關(guān)閉channel后,可以繼續(xù)向channel接收數(shù)據(jù);
// 對于nil channel,無論收發(fā)都會被阻塞。
/* close()的使用
func main() {
c := make(chan int)
go func() {
for i := 0; i < 5; i++ {
c <- i
}
//把 close(c) 注釋掉,程序會一直阻塞在 if data, ok := <-c; ok 那一行
//注釋后報錯“死鎖”:fatal error: all goroutines are asleep - deadlock!
close(c)
}()
for {
//ok為true說明channel沒有關(guān)閉,為false說明管道已經(jīng)關(guān)閉
if data, ok := <-c; ok {
fmt.Println(data)
} else {
break
}
}
fmt.Println("Finished")
}
*/
func main() {
c := make(chan int)
go func() {
for i := 0; i < 5; i++ {
c <- i
}
close(c)
}()
for data := range c {
fmt.Println(data)
}
fmt.Println("Finished")
}
免責聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點不代表本網(wǎng)站立場,如果涉及侵權(quán)請聯(lián)系站長郵箱:is@yisu.com進行舉報,并提供相關(guān)證據(jù),一經(jīng)查實,將立刻刪除涉嫌侵權(quán)內(nèi)容。