首页 > 后端开发 > Golang > 正文

为什么Go中需要等待select?

王林
发布: 2024-02-11 08:24:09
转载
1166 人浏览过

为什么Go中需要等待select?

php小编子墨介绍:在Go语言中,select语句是一种非常重要的控制流程语句,它用于同时监听多个通道的操作,实现并发控制。为什么需要等待select呢?这是因为在并发编程中,我们通常需要同时处理多个通道的数据或事件,而select语句可以帮助我们监听多个通道,一旦其中任意一个通道可操作,就会执行对应的操作,从而实现并发处理。通过使用select,我们可以有效地避免阻塞,提高程序的响应性和并发能力。

问题内容

我刚刚学习了上下文取消。 这是我的代码。

package main

import (
  "fmt"
  "context"
)

func main() {
  ctx := context.Background()

  do(ctx)
}

func do(ctx context.Context) {
  ctx, ctxCancel := context.WithCancel(ctx)

  resultCh := make(chan string)

  go terminate(ctx, resultCh)

  resultCh <- "value1"
  resultCh <- "value2"

  fmt.Println("pre cancel")

  ctxCancel()

  fmt.Println("post cancel")
}

func terminate(ctx context.Context, ch <-chan string) {
  for {
    select {
    case <-ctx.Done():
      fmt.Println("terminate")
      return
    case result := <-ch:
      fmt.Println(result)
    }
  }
}
登录后复制

想问

为什么会发生这种情况。 我需要什么知识?

我期待输出。

但得到的实际输出不包含“终止”。

value1
value2
pre cancel
terminate
post cancel
登录后复制

固定代码

我在取消功能下添加了 time.Sleep 。 那么输出就是我的预期。

ctxCancel()
time.Sleep(100 * time.Millisecond) // add
登录后复制

解决方法

据我了解,使用 select 背后的核心思想是等待至少一种情况“准备好”。我在下面提供了一个示例,可能会有所帮助。这里 select 用于等待从通道 ch 接收值或发生 1 秒超时。

import (
    "fmt"
    "time"
)

func main() {
    ch := make(chan int)

    go func() {
        // Simulate some time-consuming operation
        time.Sleep(2 * time.Second)
        ch <- 42
    }()

    select {
    case result := <-ch:
        fmt.Println("Received result:", result)
    case <-time.After(1 * time.Second):
        fmt.Println("Timeout reached")
    }
}
登录后复制

以上是为什么Go中需要等待select?的详细内容。更多信息请关注PHP中文网其他相关文章!

相关标签:
来源:stackoverflow.com
本站声明
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn
最新问题
热门教程
更多>
最新下载
更多>
网站特效
网站源码
网站素材
前端模板
关于我们 免责声明 Sitemap
PHP中文网:公益在线PHP培训,帮助PHP学习者快速成长!