channel的寫入和讀出
- 將一個(gè)數(shù)據(jù)寫入(發(fā)送)至channel的語(yǔ)法
ch <- value
向channel寫入數(shù)據(jù)通常會(huì)導(dǎo)致程序阻塞,直至有其他goroutine從這個(gè)channel中讀取數(shù)據(jù) - 從channel中讀取數(shù)據(jù)
value := <-ch
如果channel中沒(méi)有寫入數(shù)據(jù),那么從channel中讀取數(shù)據(jù)也會(huì)導(dǎo)致程序阻塞,直到channel中被寫入數(shù)據(jù)為止
select處理異步IO問(wèn)題
select {
case <- chan1:
// 如果從chan1成功讀到,則進(jìn)行該case處理語(yǔ)句
case chan2 <- 1:
// 如果成功向chan2寫入數(shù)據(jù),則進(jìn)行該case處理語(yǔ)句
default:
// 如果上面都沒(méi)有成功,進(jìn)入default處理流程
}
channel緩沖機(jī)制
創(chuàng)建一個(gè)帶緩沖的channel
c := make(chan int, 1024)
創(chuàng)建了一個(gè)大小為1024的int類型channel,即使沒(méi)有讀取方,寫入方也可以一直往channel里寫入,在緩沖區(qū)被填完之前不會(huì)阻塞
從緩沖區(qū)中讀取數(shù)據(jù)可以使用range關(guān)鍵字
for i := range c {
fmt.Println(i)
}