golang控制channel的出入口

golang控制channel的出入口

我们常常使用channel来在多个goroutine之间做数据通讯,但是chan作为函数的入参我们应该怎么写呢?也许有人觉得这个问题比较傻,不过这个还真的是我今天才知道的.

首先我们看看下面的代码:

func main() {
    c := make(chan int)
    go in(c)
    go out(c)
    time.Sleep(time.Second)
}

func in(c chan int) {
    for i := 0; i < 10; i++ {
        c <- i
    }
    close(c)
    fmt.Println("int end")
}

func out(c chan int) {
    for i := range c {
        fmt.Printf("%d\n", i)
    }
    fmt.Println("out end")
}

这个无非就是在in方法里面给channel插入10个数字,然后在out方法里面把这是个数字依次取出来(是的你没看错,range可以用于从channel中取值).

如果我想把out方法交给第三方去实现,但是我又需要输出的的数字顺序严格按照我的顺序来,也就是说我需要显式的规定out方法只能从channel中取值,不能给channel中赋值,这个时候我们应该按照下面的方式去写

type channelFunces interface{
    Out(c <-chan int)
}

一旦在实现这个out方法的时候向chan里面插入值的话,就会连编译都不过(感叹go男的严谨,大神的设计就是经典),从而我们可以通过方法的入参来限制通道的数据进出方向,那么如果想限制chan只能插入不能读出应该怎么写呢?

type channelFunces interface{
    Out(c <-chan int)
        In(c chan<- int)
}

基于这种写法我们可以在设计过程中来防止chan暴露出去数据的进出权限无法控制,当然你在参数上面不写”<-“的话,这个通道就是一个全双工的通道了,具体依据你需要编写的业务来定,不过能限制的话尽量限制住,养成良好的编码习惯,应该从这些细节开始.

时间: 2024-07-30 19:10:32

golang控制channel的出入口的相关文章

深入学习golang(2)—channel

Channel 1. 概述 “网络,并发”是Go语言的两大feature.Go语言号称“互联网的C语言”,与使用传统的C语言相比,写一个Server所使用的代码更少,也更简单.写一个Server除了网络,另外就是并发,相对python等其它语言,Go对并发支持使得它有更好的性能. Goroutine和channel是Go在“并发”方面两个核心feature. Channel是goroutine之间进行通信的一种方式,它与Unix中的管道类似. Channel声明: ChannelType = (

Golang的channel使用以及并发同步技巧

在学习<The Go Programming Language>第八章并发单元的时候还是遭遇了不少问题,和值得总结思考和记录的地方. 做一个类似于unix du命令的工具.但是阉割了一些功能,这里应该只实现-c(统计total大小) 和-h(以human比较容易辨识的显示出来)的功能. 首先我们需要构造一个 能够返回FileInfo信息数组的函数,我们把它取名为dirEntries: func dirEntries(dir string) []os.FileInfo { entries, er

使用golang的channel的坑

很多时候我们经过使用有缓冲channel作为通信控制的功能,以至有一些误解和坑出现. 误解一:有缓存channel是顺序的 执行下面代码. package mainimport (    "time"     "math/rand")func main(){     cache:=make(chan int,4)    go func() {        for i:=0;i< 10;i++ {             cache<-i        

golang中channel的超时处理

并发中超时处理是必不可少的,golang没有提供直接的超时处理机制,但可以利用select机制来解决超时问题. func timeoutFunc() { //首先,实现并执行一个匿名的超时等待函数 timeout := make(chan bool, 1) go func() { time.Sleep(1e9) //等待1秒钟 timeout <- true }() //然后,我们把timeout这个channel利用起来 select { case <- ch: //从ch中读到数据 cas

golang goroutine channel [fmt.Println=&gt;String]

初识golang,这部分也不是很了解,百度了一下,做个小记录 goroutine是golang用来做并发处理的,使用起来很简单  go func(){...}(),就是看起来随便用一般而容易go的滥用,所以使用时要仔细斟酌才好. channel 大约是用来在线程间传递数据的,主线程开通一个channel,goroutine往channel中存入内容 1.channel只能用make创建 c := make(chan int) 2.channel中存入数据 c<-2  //把2存入到channel

如何优雅的关闭golang的channel

How to Gracefully Close Channels,这篇博客讲了如何优雅的关闭channel的技巧,好好研读,收获良多. 众所周知,在golang中,关闭或者向已关闭的channel发送数据都会引发panic. 谨遵优雅关闭channel的原则 不要在接受一端关闭channel 不要在有多个并发的senders中关闭channel.反过来说,如果只有一个协程充当sender,那么我们可以在这个sender协程内关闭掉channel. 一个简单的方法 SafeClose type M

golang 之 channel

channel的机制是先进先出 无缓冲的channel: 如果你给channel赋值了,那么必须要读取它的值,不然就会造成阻塞. chreadandwrite :=make(chan int) chonlyread := make(<-chan int) //创建只读channel chonlywrite := make(chan<- int) //创建只写channel 有缓冲的channel: 发送方会一直阻塞直到数据被拷贝到缓冲区: 如果缓冲区已满,则发送方只能在接收方取走数据后才能从阻

golang 的 channel 实现 生产者/消费者 模型

package main import ( "fmt" "math/rand" "time" ) func productor(channel chan<- string) { for { channel <- fmt.Sprintf("%v", rand.Float64()) time.Sleep(time.Second * time.Duration(1)) } } func customer(channel

[golang]单向channel的应用“生产消费者模型”

单向channel应用"生产消费者模型" 单向channel最典型的应用是"生产者消费者模型" 所谓"生产者消费者模型": 某个模块(函数等)负责产生数据,这些数据由另一个模块来负责处理(此处的模块是广义的,可以是类.函数.协程.线程.进程等).产生数据的模块,就形象地称为生产者:而处理数据的模块,就称为消费者. 单单抽象出生产者和消费者,还够不上是生产者/消费者模型.该模式还需要有一个缓冲区处于生产者和消费者之间,作为一个中介.生产者把数据放入