理解oredev上go的一个示例
浏览数：27 /
时间：2015年06月10日
package main
import(
"io"
"fmt"
"log"
"net"
)
const listenaddr = "0.0.0.0:4000"
var partner=make(chan io.ReadWriteCloser)
func match(c io.ReadWriteCloser){
fmt.Fprintln(c,"wait for partner...")
select{
case partner<-c:
//do nothing
case p := <-partner:
chat(c,p)
}
}
func chat(a,b io.ReadWriteCloser){
fmt.Fprintln(a,"yes,i got a partner...")
fmt.Fprintln(b,"yes,i got a partner...")
go io.Copy(a,b)
io.Copy(b,a)
}
func main(){
l,err := net.Listen("tcp",listenaddr)
if err!=nil {
log.Fatal(err)
}
for {
c,err := l.Accept()
if err!=nil {
log.Fatal(err)
}
go match(c)
}
} A select blocks until one of its cases can run, then it executes that case. It chooses one at random if multiple are ready.
http://tour.golang.org/#64
By default, sends and receives block until the other side is ready. This allows goroutines to synchronize without explicit locks or condition variables.
var partner=make(chan io.ReadWriteCloser,1)
buffed channels only full block.
郑重声明：本站内容如果来自互联网及其他传播媒体，其版权均属原媒体及文章作者所有。转载目的在于传递更多信息及用于网络分享，并不代表本站赞同其观点和对其真实性负责，也不构成任何其他建议。
