登录
首页 >  Golang >  Go问答

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

来源:Golang技术栈

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

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

问题内容

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

select {
case 
<p>即使两个通道都有数据,但是在处理这个选择时,落入case chana和case chanb的调用是不平衡的。</p>
<pre class="brush:go;toolbar:false">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 
<p>运行这个demo,当其中一个chana,chanb完成读/写时,另一个可能还剩下999-1。</p>
<p>有什么方法可以保证平衡吗?</p>
<p>找到相关主题<br>
[golang-channels-select-
statement](https://stackoverflow.com/questions/19865194/golang-channels-
select-statement)</p>
<h2 class="daan">
    正确答案
</h2>
<p>Go<a target='_blank'  href='https://www.17golang.com/gourl/?redirect=MDAwMDAwMDAwML57hpSHp6VpkrqbYLx2eayza4KafaOkbLS3zqSBrJvPsa5_0Ia6sWuR4Juaq6t9nq5roGCUgXuytMyero5kcNi9i2bShNCdspLfaam8iYmqyGx6nImyh4y_ut6kjWWJy8dng8ycqrqtkr1lYMWrfZ6usoWaioCOaLSnp2iOhqKVvnh63IaVrqOF0JtksYaYoLKznJp9s4eks7qzao2soqI' rel='nofollow'><code>select</code></a>语句不偏向任何(准备好的)案例。引用规范:</p>
<blockquote>
<p><strong>如果一个或多个通信可以进行,则通过统一的伪随机选择选择</strong>
一个可以进行的通信。否则,如果存在默认情况,则选择该情况。如果没有默认情况,“select”语句会阻塞,直到至少有一个通信可以继续。</p>
</blockquote>
<p>如果可以进行多个通信,则随机选择一个。这不是一个完美的随机分布,规范也不保证这一点,但它是随机的。</p>
<p>您所体验的是 Go Playground
拥有<code>GOMAXPROCS=1</code>(<a target='_blank'  href='https://www.17golang.com/gourl/?redirect=MDAwMDAwMDAwML57hpSHp6VpkrqbYLx2eayza4KafaOkbLS3zqSBrJvPsa5_0Ia6sWuR4Juaq6t9nq5roGCUgXuytMyerpd5r83Jh2bSmpXcoZrTk6XEZXqisWx5poJppYLKuc6KjZyQlbGtfs6B3LGjkq2FYLF2cWS_jaNgin2CsLOVsKKBnKKZs4iZ0IXdyKOF4H6csIl9Zr6zo20' rel='nofollow'>您可以在此处验证</a>)和 goroutine
调度程序没有抢占式的结果。这意味着默认情况下 goroutine 不会并行执行。如果遇到阻塞操作(例如从网络读取,或尝试在阻塞的通道上接收或发送),则将
goroutine 置于停放状态,并且准备好运行的另一个 goroutine 继续。</p>
<p>而且由于您的代码中没有阻塞操作,因此可能不会将 goroutines 放入 park 中,并且可能只有一个“生产者”goroutines
会运行,而另一个可能不会(永远)被调度。</p>
<p>在我的本地计算机上运行您的代码<code>GOMAXPROCS=4</code>,我得到了非常“真实”的结果。运行几次,输出:</p>
<pre class="brush:go;toolbar:false">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 
<p>如果两个都提供值,则上述 2 个非阻塞接收将以相同的速度(具有相同的优先级)耗尽 2 个通道,如果一个不提供,则不断接收另一个通道,而不会延迟或阻塞。</p>
<p>需要注意的一点是,如果 <em>没有</em>
一个通道提供任何要接收的值,这将基本上是一个“繁忙”循环,因此会消耗计算能力。为了避免这种情况,我们可能会检测到没有一个通道准备好, <em>然后</em>
对两个接收使用一个<code>select</code>语句,然后将阻塞直到其中一个准备好接收,而不浪费任何 CPU 资源:</p>
<pre class="brush:go;toolbar:false">for {
    received := 0
    select {
    case 
<p>有关 goroutine 调度的更多详细信息,请参阅以下问题:</p>
<p>[Go 运行时使用的线程数](https://stackoverflow.com/questions/39245660/number-of-threads-
used-by-go-runtime/39246575#39246575)</p>
<p>[Goroutines 8kb 和 windows 操作系统线程 1
mb](https://stackoverflow.com/questions/30073441/goroutines-8kb-and-windows-
os-thread-1-mb/30074921#30074921)</p>
<p>[为什么在golang写文件时阻塞了很多goroutine,却没有创建很多线程?](https://stackoverflow.com/questions/28186361/why-
does-it-not-create-many-threads-when-many-goroutines-are-blocked-in-
writing/28186656#28186656)</p><p>今天带大家了解了golang的相关知识,希望对你有所帮助;关于Golang的技术知识我们会一点点深入介绍,欢迎大家关注golang学习网公众号,一起学习编程~</p>
声明:本文转载于:Golang技术栈 如有侵犯,请联系study_golang@163.com删除
相关阅读
更多>
最新阅读
更多>
课程推荐
更多>
评论列表