我有以下来自GoByExamples的并发渠道示例
Java中是否有等同的东西?我本以为实现同一件事会更加冗长。
// Basic sends and receives on channels are blocking. // However, we can use `select` with a `default` clause to // implement _non-blocking_ sends, receives, and even // non-blocking multi-way `select`s. package main import "fmt" func main() { messages := make(chan string) signals := make(chan bool) // Here's a non-blocking receive. If a value is // available on `messages` then `select` will take // the `<-messages` `case` with that value. If not // it will immediately take the `default` case. select { case msg := <-messages: fmt.Println("received message", msg) default: fmt.Println("no message received") } // A non-blocking send works similarly. msg := "hi" select { case messages <- msg: fmt.Println("sent message", msg) default: fmt.Println("no message sent") } // We can use multiple `case`s above the `default` // clause to implement a multi-way non-blocking // select. Here we attempt non-blocking receives // on both `messages` and `signals`. select { case msg := <-messages: fmt.Println("received message", msg) case sig := <-signals: fmt.Println("received signal", sig) default: fmt.Println("no activity") } }
Select语句 是 在Go中在语言语法级别引入并发的原因。并发函数调用可以(和通常完成)在库级别使用辅助函数(例如spawn( function())和通道)实现,就像在大多数其他语言中使用互斥或锁定的数据结构一样。但是select声明不能。
Select
spawn( function())
select