go channel
helww · · 4025 次点击 · · 开始浏览channel是golang用来线程间通信而设计的,可以理解为异步IO。常用的应用场景:等待mysql的返回值,等待curl请求的返回值,等待定时器返回等。
本来想展示channel遇到的各种错误,但是有些错误不重要,如果写出来会让整篇文章先得不那么顺畅,所以只写重要的点,忽略不重要的点。
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机制
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程调用写入进程,主线程中执行读取操作。两者的顺序不能反
channel的关闭
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则已关闭
有疑问加站长微信联系(非本文作者)
入群交流(和以上内容无关):加入Go大咖交流群,或添加微信:liuxiaoyan-s 备注:入群;或加QQ群:692541889
关注微信- 请尽量让自己的回复能够对别人有帮助
- 支持 Markdown 格式, **粗体**、~~删除线~~、
`单行代码` - 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
- 图片支持拖拽、截图粘贴等方式上传
收入到我管理的专栏 新建专栏
channel是golang用来线程间通信而设计的,可以理解为异步IO。常用的应用场景:等待mysql的返回值,等待curl请求的返回值,等待定时器返回等。
本来想展示channel遇到的各种错误,但是有些错误不重要,如果写出来会让整篇文章先得不那么顺畅,所以只写重要的点,忽略不重要的点。
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机制
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程调用写入进程,主线程中执行读取操作。两者的顺序不能反
channel的关闭
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则已关闭