看范例学 Golang (二十九)- 非阻塞 Channel 操作

非阻塞 Channel 操作

对于 Channel 基本的收发是阻塞的。但是,我们可以使用 selectdefault 来实现非阻塞的收发,或者是多路复用 io 。

package main
import "fmt"
func main() {
    messages := make(chan string)
    signals := make(chan bool)

这里实现了非阻塞的接收。如果 messages 中有值,那么 select 将会先处理这个 case ,如果 messages 中没有值,那么 select 将会直接处理 default 分支的流程。

    select {
    case msg := <-messages:
        fmt.Println("received message", msg)
    default:
        fmt.Println("no message received")
    }

非阻塞接收。

    msg := "hi"
    select {
    case messages <- msg:
        fmt.Println("sent message", msg)
    default:
        fmt.Println("no message sent")
    }

我们可以使用多个 case 分支,来实现多路非阻塞 io 处理。

    select {
    case msg := <-messages:
        fmt.Println("received message", msg)
    case sig := <-signals:
        fmt.Println("received signal", sig)
    default:
        fmt.Println("no activity")
    }
}
$ go run non-blocking-channel-operations.go
no message received
no message sent
no activity