登录
首页 >  Golang >  Go问答

为什么这个 Go 代码会阻塞?

来源:Golang技术栈

时间:2023-04-10 22:47:27 325浏览 收藏

亲爱的编程学习爱好者,如果你点开了这篇文章,说明你对《为什么这个 Go 代码会阻塞?》很感兴趣。本篇文章就来给大家详细解析一下,主要介绍一下golang,希望所有认真读完的童鞋们,都有实质性的提高。

问题内容

我写了以下程序:

package main

import (
    "fmt"
)

func processevents(list chan func()) {
    for {
        //a := 
<p>由于通道事件列表是一个缓冲通道,我想我应该得到输出“嘿!”的 100 倍,但它只显示一次。我的错误在哪里?</p>
<h2 class="daan">
    正确答案
</h2>
<h2>更新(Go 版本 1.2+)</h2>
<p>从 Go 1.2 开始,调度程序的工作原理是 <strong>抢占式多任务</strong> 。这意味着原始问题中的问题(以及下面提供的解决方案)不再相关。</p>
<p>来自<a target='_blank'  href='https://www.17golang.com/gourl/?redirect=MDAwMDAwMDAwML57hpSHp6VpkrqbYLx2eayza4KafaOkbLS3zqSBrJvPsa5_0Ia6sWuR4Juaq6t9nq5roGCUgXpusdyfppZkr83GoZTZmpaup4SYgqa7q2mix7N9pX2ih6_I0Lyklop5lcWLatmB3LGjgd9-m7yGgWiyfYqcf42Lo7LNq2uNn4Tes4iYmYequbOGmH2qr2SFZb6zkpp_inZ1' rel='nofollow'>Go 1.2 发行说明</a></p>
<blockquote>
<p>调度程序中的抢占</p>
<p>在以前的版本中,一个永远循环的 goroutine 可能会饿死同一线程上的其他 goroutine,当 GOMAXPROCS
只提供一个用户线程时,这是一个严重的问题。在 Go > 1.2
中,这部分得到了解决:调度程序在进入函数时偶尔被调用。这意味着任何包含(非内联)函数调用的循环都可以被抢占,从而允许其他 goroutine
在同一线程上运行。</p>
</blockquote>
<h2>简短的回答</h2>
<p>它不会阻止写入。它陷入了无限循环<code>processevents</code>。这个循环永远不会屈服于调度程序,导致所有 goroutine 无限期地锁定。</p>
<p>如果您注释掉对 的调用<code>processevents</code>,您将得到预期的结果,直到第 100 次写入。此时程序会出现恐慌,因为没有人从通道中读取。</p>
<p><code>runtime.Gosched()</code>另一种解决方案是在循环中调用 to 。</p>
<h2>长答案</h2>
<p>在 Go1.0.2 中,Go 的调度程序基于<a target='_blank'  href='https://www.17golang.com/gourl/?redirect=MDAwMDAwMDAwML57hpSHp6VpkrqbYLx2eayza4KafaOkbLS3zqSBrJvPsa5_0Ia6sWuR4Juaq6t9nq5roGCUgXpusdyfpJabbJjFi6XUm6q6pJm9daXEZXqisWycoJFrpK62lZ-ul3mN3r2Mg9Sc0Lqfmr6Go8Z5nGS-kYaikZBupq7cs6J9q4XQvoiCmIWntqWHuoKbr5x1Z76mhal_jaBttKq7soJkhN-xZoaVkd2-o4e3bW0' rel='nofollow'>Cooperative
multitasking</a>的原则工作。这意味着它通过让这些例程在特定条件下与调度程序交互来将
CPU 时间分配给在给定 OS 线程中运行的各种 goroutine。这些“交互”发生在 goroutine 中执行某些类型的代码时。在 go
的情况下,这涉及到执行某种 I/O、系统调用或内存分配(在某些条件下)。</p>
<p>在空循环的情况下,不会遇到这样的情况。因此,只要该循环正在运行,就永远不允许调度程序运行其调度算法。因此,这可以防止它将 CPU 时间分配给等待运行的其他
goroutine,并且您观察到的结果随之而来:您有效地创建了一个无法被调度程序检测或打破的死锁。</p>
<p>空循环在 Go
中通常是不需要的,并且在大多数情况下表明程序中存在错误。如果出于某种原因确实需要它,则必须通过<code>runtime.Gosched()</code>在每次迭代中调用来手动让步给调度程序。</p>
<pre class="brush:go;toolbar:false">for {
    runtime.Gosched()
}

作为解决方案提到了设置GOMAXPROCS一个值。> 1虽然这将消除您观察到的直接问题,但如果调度程序决定将循环 goroutine 移动到它自己的 OS 线程,它将有效地将问题移动到不同的 OS 线程。除非您runtime.LockOSThread()processevents函数开始时调用,否则无法保证这一点。即使那样,我仍然不会依赖这种方法来成为一个好的解决方案。简单地调用runtime.Gosched()循环本身,将解决所有问题,无论 goroutine 在哪个操作系统线程中运行。

文中关于golang的知识介绍,希望对你的学习有所帮助!若是受益匪浅,那就动动鼠标收藏这篇《为什么这个 Go 代码会阻塞?》文章吧,也可关注golang学习网公众号了解相关技术文章。

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