广告位联系
返回顶部
分享到

golang并发编程使用Select语句的实现介绍

Golang 来源:互联网 作者:佚名 发布时间:2024-10-18 22:41:14 人浏览
摘要

在 Go 语言中,select语句是一种控制结构,允许一个 Goroutine 同时等待多个通道操作。select语句会阻塞,直到其中的一个case可以继续执行,然后执行该case中的语句。select语句是处理并发任务时非

在 Go 语言中,select 语句是一种控制结构,允许一个 Goroutine 同时等待多个通道操作。select 语句会阻塞,直到其中的一个 case 可以继续执行,然后执行该 case 中的语句。select 语句是处理并发任务时非常有用的工具,特别是需要处理多个通道的通信时。

select 语句的基本用法

1

2

3

4

5

6

7

8

9

10

select {

case val1 := <-ch1:

    // 当从 ch1 接收到数据时执行

case ch2 <- val2:

    // 当向 ch2 发送数据时执行

case <-time.After(time.Second):

    // 如果一秒内没有任何通道操作成功,则执行此 case

default:

    // 如果没有任何通道操作成功,立即执行此 case

}

示例代码

下面是一些使用 select 语句的示例,以展示其灵活性和强大之处。

示例 1:从多个通道接收数据

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

package main

 

import (

    "fmt"

    "time"

)

 

func main() {

    ch1 := make(chan int)

    ch2 := make(chan int)

 

    go func() {

        time.Sleep(time.Second)

        ch1 <- 1

    }()

 

    go func() {

        time.Sleep(2 * time.Second)

        ch2 <- 2

    }()

 

    for i := 0; i < 2; i++ {

        select {

        case msg1 := <-ch1:

            fmt.Println("Received", msg1)

        case msg2 := <-ch2:

            fmt.Println("Received", msg2)

        }

    }

}

这个示例中,两个 Goroutine 分别在不同的时间向 ch1 和 ch2 发送数据,select 语句能够处理哪个通道先接收到数据。

示例 2:实现超时机制

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

package main

 

import (

    "fmt"

    "time"

)

 

func main() {

    ch := make(chan int)

 

    go func() {

        time.Sleep(2 * time.Second)

        ch <- 42

    }()

 

    select {

    case msg := <-ch:

        fmt.Println("Received:", msg)

    case <-time.After(1 * time.Second):

        fmt.Println("Timeout")

    }

}

在这个示例中,select 语句中包含了一个超时机制,如果一秒内没有接收到数据,则会执行超时的 case。

示例 3:非阻塞的通道操作

1

2

3

4

5

6

7

8

9

10

11

12

13

14

package main

 

import "fmt"

 

func main() {

    ch := make(chan int)

 

    select {

    case msg := <-ch:

        fmt.Println("Received:", msg)

    default:

        fmt.Println("No data received")

    }

}

在这个示例中,select 语句的 default 分支使得通道操作变得非阻塞,如果没有数据接收,则会立即执行 default 分支。

select 语句的注意事项

  • 随机选择:如果有多个 case 都可以执行,select 会随机选择一个执行。
  • 避免阻塞:使用 default 分支可以避免 select 语句阻塞。
  • 通道关闭:如果一个通道关闭且仍有数据在缓冲区中,select 语句可以正常接收到数据,但之后会立即返回零值。

高级用法

你可以通过将多个通道操作组合在一起,使用 select 语句构建复杂的并发逻辑。例如,可以实现优先级通道、动态增加或减少通道的数量等。

通过灵活运用 select 语句,Go 程序员能够高效地处理并发任务,使得代码更加简洁和易于维护。


版权声明 : 本文内容来源于互联网或用户自行发布贡献,该文观点仅代表原作者本人。本站仅提供信息存储空间服务和不拥有所有权,不承担相关法律责任。如发现本站有涉嫌抄袭侵权, 违法违规的内容, 请发送邮件至2530232025#qq.cn(#换@)举报,一经查实,本站将立刻删除。
原文链接 :
相关文章
  • golang日志库ZAP[uber-go zap]示例介绍
    golang 日志库ZAP[uber-go zap] 1. 简要说明 zap 是 uber 开源的 Go 高性能日志库,支持不同的日志级别, 能够打印基本信息等,但不支持日志的分割
  • golang并发编程使用Select语句的实现介绍
    在 Go 语言中,select语句是一种控制结构,允许一个 Goroutine 同时等待多个通道操作。select语句会阻塞,直到其中的一个case可以继续执行,然
  • go语言time.After()的作用介绍
    time.After是一个非常实用的函数,它返回一个用于读取的单向通道(-chan time.Time),这个通道会在指定的时间间隔之后发送当前时间。这个机
  • go实现一个内存缓存系统的代码
    面试内容: 支持设定过期时间,精度到秒 支持设定最大内存,当内存超出时做出合适的处理 支持并发安全 要求按照以下接口实现 1 2 3 4
  • Golang Map简介以及底层原理介绍
    在Go语言中提供了map数据结构来存储键值对数据。map的数据类型为map[K]V,其中K为键的类型,V为值的类型。map的键类型必须支持==操作符,用
  • Go语言中的switch高级用法介绍
    最近翻开源代码的时候看到了一种很有意思的switch用法,分享一下。 注意这里讨论的不是typed switch,也就是case语句后面是类型的那种。 直
  • Go语言sync.Map介绍及使用场景
    在 Go 语言中,sync.Map是一个并发安全的映射结构,专门用于在高并发场景下处理键值对数据。它的并发安全是通过内部实现机制来保证的,
  • 怎么使用工具自动监测SSL证书有效期并发送提醒
    自从云厂商的免费ssl证书改成3个月,而且证书数量还是20个之后,自己网站的ssl证书就换成了其它免费方案。但是免费方案不会提醒证书过
  • Go语言字符串处理库strings包介绍

    Go语言字符串处理库strings包介绍
    Golang字符串处理库strings 在Go语言中,strings包是一个非常重要且功能丰富的标准库,它提供了一系列用于操作字符串的函数。从基本的字符串
  • Go语言中的指针的使用介绍
    1、Go 语言中指针的介绍 1.1、什么是指针? 指针是一种变量,它存储了另一个变量的内存地址。在 Go 中,你可以通过取地址操作符获取变量
  • 本站所有内容来源于互联网或用户自行发布,本站仅提供信息存储空间服务,不拥有版权,不承担法律责任。如有侵犯您的权益,请您联系站长处理!
  • Copyright © 2017-2022 F11.CN All Rights Reserved. F11站长开发者网 版权所有 | 苏ICP备2022031554号-1 | 51LA统计