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

Question

我写了以下程序:

package main

import (
    "fmt"
)

func processevents(list chan func()) {
    for {
        //a := <-list
        //a()
    }
}

func test() {
    fmt.Println("Ho!")
}

func main() {

    eventlist := make(chan func(), 100)

    go processevents(eventlist)

    for {
        eventlist <- test
        fmt.Println("Hey!")
    }
}

由于频道事件列表是一个缓冲频道,我想我应该得到输出"嘿!"的100倍,但它只显示一次.我的错误在哪里？

Answer 1

更新(转到版本1.2+)

从Go 1.2开始,调度程序的工作原理是先发制人的多任务处理.这意味着原始问题(以及下面介绍的解决方案)中的问题不再相关.

来自Go 1.2发行说明

调度程序中的抢占

在以前的版本中,永远循环的goroutine可能会在同一个线程上饿死其他goroutine,这是GOMAXPROCS只提供一个用户线程时的一个严重问题.在Go> 1.2中,部分解决了这个问题:在进入函数时偶尔会调用调度程序.这意味着任何包含(非内联)函数调用的循环都可以被抢占,允许其他goroutine在同一个线程上运行.

简短的回答

它不会阻止写入.它被困在无限循环中processevents.这个循环永远不会产生调度程序,导致所有goroutine无限期地锁定.

如果您将呼叫注释掉processevents,您将获得预期的结果,直到第100次写入.程序在此时会感到恐慌,因为没有人从频道中读取内容.

另一个解决方案是runtime.Gosched()在循环中调用.

答案很长

使用Go1.0.2,Go的调度程序基于协作式多任务处理原理.这意味着它通过让这些例程在某些条件下与调度程序交互,将CPU时间分配给在给定OS线程内运行的各种goroutine.当在goroutine中执行某些类型的代码时,会发生这些"交互".在go的情况下,这涉及进行某种I/O,系统调用或内存分配(在某些条件下).

在空循环的情况下,不会遇到这样的情况.因此,只要该循环正在运行,就不允许调度程序运行其调度算法.这因此可以防止它将CPU时间分配给等待运行的其他goroutine,并且您观察到的结果随之发生:您有效地创建了一个无法被调度程序检测到或者中断的死锁.

在Go中通常不需要空循环,并且在大多数情况下,将指示程序中的错误.如果由于某种原因确实需要它,则必须通过调用runtime.Gosched()每次迭代来手动屈服于调度程序.

for {
    runtime.Gosched()
}

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

Answer 2

这是另一种解决方案 - 用于range从频道中读取.此代码将正确地生成调度程序,并在通道关闭时正确终止.

func processevents(list chan func()) {
    for a := range list{
        a()
    }
}