Go 语言编程实例(一)
通道实例
通道是连接并发 goroutine 的管道。可以从一个 goroutine 向通道发送值,并在另外一个 goroutine 中接收到这些值。
使用 make(chan val-type) 创建一个新通道,通道由输入的值传入。使用通道 <- 语法将值发送到通道。这里从一个新的 goroutine 发送 “ping” 到上面的消息通道。
<-channel 语法从通道接收值。在这里,将收到上面发送的 ping 消息并打印出来。当运行程序时 ping 消息通过通道成功地从一个 goroutine 传递到另一个 goroutine 。默认情况下发送和接收块,直到发送方和接收方都准备好。此属性允许在程序结束时等待 ping 消息,而不必要使用任何其他同步。
示例代码:
package main
import "fmt"
func main(){
//创建一个新的通道使用下面的方法
messages := make(chan string)
//发送一个值
go func(){message <- "ping"}()
//接收一个值
msg:= <-messages
fmt.Println(msg)
}
通道缓冲实例
默认情况下,通道是未缓冲的,意味着如果有相应的接收 (<-chan)准备好接收发送的值,它们将只接受发送 (chan<-)。缓冲通道接受有限数量的值,而没有用于这些值的相应接收器。
这里使一个字符串的通道缓冲达到 2 个值。因为这个通道被缓冲,所以可以将这些值发送到通道中,而没有相应的并发接收。
之后可以照常接收这两个值。
代码示例如下:
package main
import "fmt"
func main(){
messages := make(chan string,2)
messages <- "buffered"
messages <- "channel"
fmt.Println(<-messages)
fmt.Println(<-messages)
}
通道同步实例
我们可以使用通道在 goroutine 上同步执行程序。这里有一个使用阻塞接收等待 goroutine 完成示例。
这是将在 goroutine 中运行的函数。 done 通道将用来通知另一个 goroutine 这个函数的工作已经完成,发送值以通知已经完成。
启动一个 goroutine 工作程序,给它一个通知通道。如果从此程序中删除 <-done 行,程序将在工作程序(worker)启动之前退出。
阻止,知道在通道上收到工作程序的通知。
package main
import (
"fmt"
"time"
)
func worker(done chan bool){
fmt.Print("workding...")
time.Sleep(time.Second)
fmt.Println("done")
done <- true
}
func main(){
done := make (chan bool,1)
go worker(done)
<-done
}
通道路线实例
当使用通道作为函数参数的时候,可以指定通道是否仅用于发送或者接收值。这种特殊性增加了程序的类型安全性。
此 ping 功能直接收用于发送值的通道,尝试在此频道上接收将是一个编译时错误。ping 函数接收一个通道接收 ping值,一个接受发送 ping值。
package main
import "fmt"
//只接收通道发送数据
func ping(pings chan <- string,msg string){
pings<-msg
}
//只接收通道接收数据
//pong send
func pong(pings<-chan string,pongs chan<- string){
msg := <- pings
pongs <- msg
}
func main(){
pings := make(chan string,1)
pongs := make(chan string,1)
ping (pings,"passed message")
pong (pings,pongs)
fmt.Println(<-pongs)
}