平武建站

Channel怎么在Golang中使用-创新互联

本篇文章为大家展示了Channel 怎么在Golang中使用，内容简明扼要并且容易理解，绝对能使你眼前一亮，通过这篇文章的详细介绍希望你能有所收获。

创新互联建站网站建设提供从项目策划、软件开发，软件安全维护、网站优化(SEO)、网站分析、效果评估等整套的建站服务，主营业务为网站建设、网站设计，app软件定制开发以传统方式定制建设网站，并提供域名空间备案等一条龙服务，秉承以专业、用心的态度为用户提供真诚的服务。创新互联建站深信只要达到每一位用户的要求，就会得到认可，从而选择与我们长期合作。这样，我们也可以走得更远！

channel 是干什么的

意义：channel 是用来通信的

实际上：（数据拷贝了一份，并通过 channel 传递，本质就是个队列）

channel 应该用在什么地方

核心：需要通信的地方

例如以下场景：

  • 通知广播

  • 交换数据

  • 显式同步

  • 并发控制

  • ...

记住！channel 不是用来实现锁机制的，虽然有些地方可以用它来实现类似读写锁，保护临界区的功能，但不要这么用！

channel 用例实现

超时控制

// 利用 time.After 实现
func main() {
  done := do()
  select {
  case <-done:
    // logic
  case <-time.After(3 * time.Second):
    // timeout
  }
}

func do() <-chan struct{} {
  done := make(chan struct{})
  go func() {
    // do something
    // ...
    done <- struct{}{}
  }()
  return done
}

取最快的结果

比较常见的一个场景是重试，第一个请求在指定超时时间内没有返回结果，这时重试第二次，取两次中最快返回的结果使用。
超时控制在上面有，下面代码部分就简单实现调用多次了。

func main() {
  ret := make(chan string, 3)
  for i := 0; i < cap(ret); i++ {
    go call(ret)
  }
    fmt.Println(<-ret)
}

func call(ret chan<- string) {
  // do something
  // ...
  ret <- "result"
}

限制大并发数

// 大并发数为 2
limits := make(chan struct{}, 2)
for i := 0; i < 10; i++ {
  go func() {
    // 缓冲区满了就会阻塞在这
    limits <- struct{}{}
    do()
    <-limits
  }()
}

for...range 优先

for ... range c { do } 这种写法相当于 if _, ok := <-c; ok { do }

func main() {
  c := make(chan int, 20)
  go func() {
    for i := 0; i < 10; i++ {
      c <- i
    }
    close(c)
  }()
  // 当 c 被关闭后，取完里面的元素就会跳出循环
  for x := range c {
    fmt.Println(x)
  }
}

多个 goroutine 同步响应

利用 close 广播

func main() {
  c := make(chan struct{})
  for i := 0; i < 5; i++ {
    go do(c)
  }
  close(c)
}

func do(c <-chan struct{}) {
  // 会阻塞直到收到 close
  <-c
  fmt.Println("hello")
}

非阻塞的 select

select 本身是阻塞的，当所有分支都不满足就会一直阻塞，如果想不阻塞，那么一个什么都不干的 default 分支是最好的选择

select {
case <-done:
  return
default:  
}

for{select{}} 终止

尽量不要用 break label 形式，而是把终止循环的条件放到 for 条件里来实现

for ok {
  select {
  case ch <- 0:
  case <-done:
    ok = false
  }
}

channel 特性

基础特性

操作值为 nil 的 channel被关闭的 channel正常的 channel
closepanicpanic成功关闭
c<-永远阻塞panic阻塞或成功发送
<-c永远阻塞永远不阻塞阻塞或成功接收

happens-before 特性

  1. 无缓冲时，接收 happens-before 发送

  2. 任何情况下，发送 happens-before 接收

  3. close happens-before 接收

上述内容就是Channel 怎么在Golang中使用，你们学到知识或技能了吗？如果还想学到更多技能或者丰富自己的知识储备，欢迎关注创新互联成都网站设计公司行业资讯频道。

另外有需要云服务器可以了解下创新互联scvps.cn，海内外云服务器15元起步，三天无理由+7*72小时售后在线，公司持有idc许可证，提供“云服务器、裸金属服务器、高防服务器、香港服务器、美国服务器、虚拟主机、免备案服务器”等云主机租用服务以及企业上云的综合解决方案，具有“安全稳定、简单易用、服务可用性高、性价比高”等特点与优势，专为企业上云打造定制，能够满足用户丰富、多元化的应用场景需求。


名称栏目：Channel怎么在Golang中使用-创新互联
文章路径：http://pwwzsj.com/article/dpsgph.html

其他资讯