您好,登錄后才能下訂單哦!
// select.go
package main
import (
"fmt"
"time"
//"time"
)
func main() {
//聲明一個channel
ch := make(chan int)
//聲明一個匿名函數,傳入一個參數整型channel類型ch
go func(ch chan int) {
ch <- 1
//往channel寫入一個數據,此時阻塞
}(ch)
//由于goroutine執行太快,先讓它sleep 1秒
time.Sleep(time.Second)
select {
//讀取ch,解除阻塞
case <-ch:
fmt.Print("come to read ch!")
default:
fmt.Print("come to default!")
}
}
// select.go
//整型channel類型ch一直處于讀取狀態,所以處于阻塞,使用select實現超時控制
package main
import (
"fmt"
"time"
)
func main() {
ch := make(chan int)
//buffer channel,1個元素前非阻塞
timeout := make(chan int, 1)
go func() {
time.Sleep(time.Second)
//寫channel
timeout <- 1
}()
select {
//讀channel
case <-ch:
fmt.Print("come to read ch!")
//沒有讀到channel,實現超時控制
case <-timeout:
fmt.Print("come to timeout!")
}
fmt.Print("end of code!")
}
// select.go
//使用time.After實現超時控制
package main
import (
"fmt"
"time"
)
func main() {
ch := make(chan int)
select {
case <-ch:
fmt.Print("come to read ch!")
case <-time.After(time.Second):
fmt.Print("come to timeout!")
}
fmt.Print("end of code!")
}
免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。