登录
首页 >  Golang >  Go问答

当涉及多个通道时,选择如何工作?

来源:Golang技术栈

时间:2023-03-09 17:59:59 254浏览 收藏

在Golang实战开发的过程中,我们经常会遇到一些这样那样的问题,然后要卡好半天,等问题解决了才发现原来一些细节知识点还是没有掌握好。今天golang学习网就整理分享《当涉及多个通道时,选择如何工作?》,聊聊golang,希望可以帮助到正在努力赚钱的你。

问题内容

我在多个非缓冲通道上使用 select 时发现

select {
case 

即使两个通道都有数据,但是在处理这个选择时,落入case chana和case chanb的调用是不平衡的。

package main

import (
    "fmt"
    _ "net/http/pprof"
    "sync"
    "time"
)

func main() {
    chana := make(chan int)
    chanb := make(chan int)

    go func() {
        for i := 0; i 

运行这个demo,当其中一个chana,chanb完成读/写时,另一个可能还剩下999-1。

有什么方法可以保证平衡吗?

找到相关主题
[golang-channels-select- statement](https://stackoverflow.com/questions/19865194/golang-channels- select-statement)

正确答案

Goselect语句不偏向任何(准备好的)案例。引用规范:

如果一个或多个通信可以进行,则通过统一的伪随机选择选择 一个可以进行的通信。否则,如果存在默认情况,则选择该情况。如果没有默认情况,“select”语句会阻塞,直到至少有一个通信可以继续。

如果可以进行多个通信,则随机选择一个。这不是一个完美的随机分布,规范也不保证这一点,但它是随机的。

您所体验的是 Go Playground 拥有GOMAXPROCS=1您可以在此处验证)和 goroutine 调度程序没有抢占式的结果。这意味着默认情况下 goroutine 不会并行执行。如果遇到阻塞操作(例如从网络读取,或尝试在阻塞的通道上接收或发送),则将 goroutine 置于停放状态,并且准备好运行的另一个 goroutine 继续。

而且由于您的代码中没有阻塞操作,因此可能不会将 goroutines 放入 park 中,并且可能只有一个“生产者”goroutines 会运行,而另一个可能不会(永远)被调度。

在我的本地计算机上运行您的代码GOMAXPROCS=4,我得到了非常“真实”的结果。运行几次,输出:

finish one acount, bcount 1000 901
finish one acount, bcount 1000 335
finish one acount, bcount 1000 872
finish one acount, bcount 427 1000

如果您需要对单个案例进行优先级排序,请查看此答案:[Go select statement 的强制优先级](https://stackoverflow.com/questions/46200343/force-priority-of-go- select-statement/46202533#46202533)

的默认行为select不保证同等优先级,但平均而言会接近它。如果您需要保证相同的优先级,那么您不应该使用select,但您可以从 2 个通道执行 2 个非阻塞接收的序列,这可能看起来像这样:

for {
    select {
    case 

如果两个都提供值,则上述 2 个非阻塞接收将以相同的速度(具有相同的优先级)耗尽 2 个通道,如果一个不提供,则不断接收另一个通道,而不会延迟或阻塞。

需要注意的一点是,如果 没有 一个通道提供任何要接收的值,这将基本上是一个“繁忙”循环,因此会消耗计算能力。为了避免这种情况,我们可能会检测到没有一个通道准备好, 然后 对两个接收使用一个select语句,然后将阻塞直到其中一个准备好接收,而不浪费任何 CPU 资源:

for {
    received := 0
    select {
    case 

有关 goroutine 调度的更多详细信息,请参阅以下问题:

[Go 运行时使用的线程数](https://stackoverflow.com/questions/39245660/number-of-threads- used-by-go-runtime/39246575#39246575)

[Goroutines 8kb 和 windows 操作系统线程 1 mb](https://stackoverflow.com/questions/30073441/goroutines-8kb-and-windows- os-thread-1-mb/30074921#30074921)

[为什么在golang写文件时阻塞了很多goroutine,却没有创建很多线程?](https://stackoverflow.com/questions/28186361/why- does-it-not-create-many-threads-when-many-goroutines-are-blocked-in- writing/28186656#28186656)

今天带大家了解了golang的相关知识,希望对你有所帮助;关于Golang的技术知识我们会一点点深入介绍,欢迎大家关注golang学习网公众号,一起学习编程~

声明:本文转载于:Golang技术栈 如有侵犯,请联系study_golang@163.com删除
相关阅读
更多>
最新阅读
更多>
课程推荐
更多>
评论列表