3 回答
TA贡献1798条经验 获得超3个赞
您遇到了 Go 调度程序的一个棘手问题。答案是这os.Exit 确实会导致整个进程退出,但是按照您的方式,goroutines 从未运行。
可能发生的情况是 for 循环不断向可用 goroutine 列表中添加新的 goroutine,但是由于整个进程仅在一个 OS 线程中运行,因此 Go 调度程序从未真正安排过不同的 goroutine,只是继续运行它for 循环而无需运行您生成的任何 goroutine。试试这个:
package main
import "os"
func main() {
for {
go func() { os.Exit(0) }()
func() {}()
}
}
如果您在 Go Playground 上运行它,它应该可以工作(实际上,这是一个链接)。
好的,上面的代码可以运行而你的代码不运行的事实应该很神秘。这样做的原因是 Go 调度程序实际上是非抢占的。这意味着除非给定的 goroutine 自愿决定给调度程序运行其他东西的选项,否则其他任何东西都不会运行。
显然,您从未编写过包含让调度程序有机会运行的命令的代码。发生的情况是,当您的代码被编译时,Go 编译器会自动将这些插入到您的代码中。这是上述代码为何起作用的关键:goroutine 可能决定运行调度程序的时间之一是调用函数时。因此,通过添加func() {}()调用(显然什么都不做),我们允许编译器添加对调度程序的调用,让这段代码有机会调度不同的 goroutine。因此,产生的 goroutine 之一运行,调用os.Exit,然后进程退出。
编辑:在编译器内联调用的情况下,函数调用本身可能是不够的(或者,在这种情况下,因为它什么都不做而完全删除它)。runtime.Gosched(),另一方面,保证工作。
TA贡献1820条经验 获得超10个赞
您可以通过从函数返回来终止 goroutine。如果需要确保 goroutine 运行完成,则需要等待 goroutine 完成。这通常是通过sync.WaitGroup, 或通过通道同步 goroutine 来完成的。
在您的示例中,您首先需要确保不可能产生无限数量的 goroutine。因为main新的 goroutine之间没有同步点,所以不能保证os.Exit在主循环运行时它们中的任何一个都会执行调用。
等待任意数量的 goroutine 完成的通常方法是使用 a sync.WaitGroup,这将确保它们在main退出之前都已执行。
wg := sync.WaitGroup{}
for i := 0; i < 10000; i++ {
wg.Add(1)
go func() { defer wg.Done() }()
}
wg.Wait()
fmt.Println("done")
TA贡献1880条经验 获得超4个赞
实施死手或终止开关
package main
import (
"fmt"
"time"
"os"
)
const maxNoTickle = 50 // will bail out after this many no tickles
const maxWorking = 20 // pretendWork() will tickle this many times
const deadTicks = 250 // milliseconds for deadHand() to check for tickles
const reportTickles = 4 // consecutive tickles or no tickles to print something
var (
tickleMe bool // tell deadHand() we're still alive
countNoTickle int // consecutive no tickles
countGotTickle int // consecutive tickles
)
/**
* deadHand() - callback to kill program if nobody checks in after some period
*/
func deadHand() {
if !tickleMe {
countNoTickle++
countGotTickle = 0
if countNoTickle > maxNoTickle {
fmt.Println("No tickle max time reached. Bailing out!")
// panic("No real panic. Just checking stack")
os.Exit(0)
}
if countNoTickle % reportTickles == 0 {
// print dot for consecutive no tickles
fmt.Printf(".")
}
} else {
countNoTickle = 0
countGotTickle++
tickleMe = false // FIXME: might have race condition here
if countGotTickle % reportTickles == 0 {
// print tilda for consecutive tickles
fmt.Printf("~")
}
}
// call ourselves again
time.AfterFunc(deadTicks * time.Millisecond, deadHand)
}
/**
* init() - required to start deadHand
*/
func init() {
time.AfterFunc(250 * time.Millisecond, deadHand)
tickleMe = true
}
/**
* pretendWork() - your stuff that does its thing
*/
func pretendWork() {
for count := 0; count < maxWorking; count++ {
tickleMe = true // FIXME: might have race condition here
// print W pretending to be busy
fmt.Printf("W")
time.Sleep(100 * time.Millisecond)
}
}
func main() {
go workTillDone()
for {
// oops, program went loop-d-loopy
}
}
- 3 回答
- 0 关注
- 233 浏览
添加回答
举报