go语言中怎么使用select

发布时间:2022-05-13 13:48:23 作者:iii
来源:亿速云 阅读:208

这篇文章主要介绍“go语言中怎么使用select”的相关知识,小编通过实际案例向大家展示操作过程,操作方法简单快捷,实用性强,希望这篇“go语言中怎么使用select”文章能帮助大家解决问题。

在golang语言中,select语句 就是用来监听和channel有关的IO操作,当IO操作发生时,触发相应的case动作。

有了 select语句,可以实现 main主线程 与 goroutine线程 之间的互动。

1.基本语法

select {
    case <-ch2 :     // 检测有没有数据可读
        // 一旦成功读取到数据,则进行该case处理语句
    case ch3 <- 1 :  // 检测有没有数据可写
        // 一旦成功向ch3写入数据,则进行该case处理语句
    default:
        // 如果以上都没有符合条件,那么进入default处理流程
}

注意事项

(1)多个IO操作发生时,case语句是随机执行的

func main()  {
    ch2 := make(chan int, 1)   // 创建 一个长度带缓冲的整型通道
    ch2 <- 1                   // 向通道中写入数据

    ch3 := make(chan int, 1)
    ch3 <- 2

    select {
        case <- ch2:
            fmt.Println("ch2 read")
        case <- ch3:
            fmt.Println("ch3 read")
    }
}

多次执行后,会随机打印 “ch2 read” 或 “ch3 read”

(2)空select语句

func main()  {
    select {
    
    }
}

执行后,引发死锁,打印如下:

fatal error: all goroutines are asleep - deadlock!

goroutine 1 [select (no cases)]:
main.main()
        xxx/test.go:4 +0x27
exit status 2

(3)for中的select 引起CPU资源消耗过高

func main()  {
    quit := make(chan bool)
    go func() {
        for {
            select {
            case <-quit:
                fmt.Println("quit")
                // 使用 return 就会退出整个goroutine线程;如果使用 break,程序仍然在for循环中执行
                return
            default:
                fmt.Println("default")
            }
        }
    }()

    time.Sleep(3 * time.Second)
    quit <- true          // 主线程在3秒后,向quit信道写入数据
    
    time.Sleep(2 * time.Second)
    fmt.Println("main")
}

在for{}的select语句中使用了 default后,线程就会无限执行default条件,直到quit信道中读到数据,否则会一直在一个死循环中运行,从而导致占满整个CPU资源。

在 for{}的select语句中,不建议使用 default条件。

2.select语句的实际应用

(1)实现 main主线程与 goroutine线程 之间的交互、通信

// 通过控制台输入 "bye", 来控制main函数结束运行
func main()  {
    quit := make(chan bool)
    ch := make(chan string)

    go func() {
        for {
            select {
            case name := <-ch:
                fmt.Printf("from main msg: [%v]\n", name)
                if name == "bye" {
                    quit <- true
                } else {
                    quit <- false
                }
            }
        }
    }()

    for {
        // 控制台输入
        fmt.Print("please input string: ")
        scanner := bufio.NewScanner(os.Stdin)
        scanner.Scan()
        ch <- scanner.Text()

        isOver := <- quit
        if isOver {
            break
        }
    }
    fmt.Println("main over")
}

运行:

from main msg: [aaa]
please input string: bbb
from main msg: [bbb]
please input string: bye
from main msg: [bye]
main over

(2)超时实现

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

    go func() {
        for {
            select {
            case num := <- ch:
                fmt.Println("num = ", num)
            case <- time.After(5 * time.Second):
                fmt.Println("超时")
                quit <- true
            }
        }
    }()

    for i := 0; i < 2; i++ {
        ch <- i
        time.Sleep(time.Second)
    }
    <- quit                   // 等待超时后, 结束 main主线程
    fmt.Println("程序结束")
}

关于“go语言中怎么使用select”的内容就介绍到这里了,感谢大家的阅读。如果想了解更多行业相关的知识,可以关注亿速云行业资讯频道,小编每天都会为大家更新不同的知识点。

推荐阅读:
  1. sybase中如何使用select into
  2. GO语言method、interface、reflection、select

免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。

go语言 select

上一篇:Python pluggy模块如何使用

下一篇:python中列表添加的四种方法是什么

相关阅读

您好,登录后才能下订单哦!

密码登录
登录注册
其他方式登录
点击 登录注册 即表示同意《亿速云用户服务条款》