标签：
channel是golang用来线程间通信而设计的，可以理解为异步IO。常用的应用场景：等待mysql的返回值，等待curl请求的返回值，等待定时器返回等。
本来想展示channel遇到的各种错误，但是有些错误不重要，如果写出来会让整篇文章先得不那么顺畅，所以只写重要的点，忽略不重要的点。
初步理解：channel可以理解为buffer，支持写入操作和读取操作。
package main import ( "fmt" ) var _ = fmt.Sprintf("") var ch chan int = make(chan int, 1) func main() { //写入channel ch <- 1 //读取channel mych := <-ch fmt.Println(mych) var stop string fmt.Scanln(&stop) fmt.Println(stop) }
输出：
1
abc
abc
注意：channel的写入和读取最好是成对使用，如果不成对出现的话，读者可能需要自己实践和考虑下。
select可以用来判断channel是否超时
select支持多个channel的等待，如果有一个返回则继续执行，也支持default（对default没有遇到合适的例子）。
想象一种场景，主线程在等待某个channel返回，但是该channel执行时间过长，主线程判断超时需要继续执行，而不是永久等待。这种场景下就能用到select。看下面的例子
package main import ( "fmt" "runtime" "time" ) var _ = fmt.Sprintf("") var ch chan int = make(chan int, 1) func main() { runtime.GOMAXPROCS(runtime.NumCPU()) go writeCh() readCh() var stop string fmt.Scanln(&stop) fmt.Println(stop) } func readCh() { select { case ch1 := <-ch: fmt.Println(ch1) return //设置1秒超时 case <-time.After(time.Second): fmt.Println("read timeout") } } func writeCh() { //等待2秒后写入，使超时生效 time.Sleep(time.Second * 2) ch <- 1 } /* 输出： read timeout abc abc */
注意：这个例子中引入了select和go rountine，读取进程依据两个channel的返回次序执行，先返回先执行。可以看到timeout先返回。（可以试试把writeCh的Sleep去掉）
推荐的调用顺序是和上面例子是一致的，先go程调用写入进程，主线程中执行读取操作。两者的顺序不能反
package main import ( "fmt" "runtime" "time" ) var _ = fmt.Sprintf("") var ch chan int = make(chan int, 1) func main() { runtime.GOMAXPROCS(runtime.NumCPU()) go writeCh() readCh() var stop string fmt.Scanln(&stop) fmt.Println(stop) close(ch) var more bool var chi int //第一个返回channel的值，第二个返回是否还有更多的数据 chi, more = <-ch fmt.Println(chi, more) //关闭后再往channel中写入会报错 //ch <- 1 } func readCh() { select { case ch1 := <-ch: fmt.Println(ch1) case <-time.After(time.Second): fmt.Println("read timeout") } } func writeCh() { //time.Sleep(time.Second * 2) ch <- 1 } /* 输出： 1 abc abc 0 false */
关闭channel用close()函数即可，判断某个channel是否已关闭，用channel的第二个返回值即可，如果为false则已关闭
标签：
原文地址：http://www.cnblogs.com/helww/p/4885712.html
