为了账号安全,请及时绑定邮箱和手机立即绑定

Golang:为什么 os.Exit 在 goroutines 中不起作用

Golang:为什么 os.Exit 在 goroutines 中不起作用

Go
喵喵时光机 2021-12-07 14:20:22
我有一个算法非常简单的研究程序。当成功到来时,goroutine 应该通过 os.Exit(0) 关闭(结束)。我等一天,两天……什么?:)这是简单的代码package mainimport "os"func main() {    for {        go func() { os.Exit(0) }()    }}我的问题:为什么 os.Exit 不终止 goroutine?终止(停止)goroutine 执行的正确方法是什么?游乐场:http : //play.golang.org/p/GAeOI-1Ksc
查看完整描述

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(),另一方面,保证工作。


查看完整回答
反对 回复 2021-12-07
?
拉莫斯之舞

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")


查看完整回答
反对 回复 2021-12-07
?
慕村225694

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

        }

}


查看完整回答
反对 回复 2021-12-07
  • 3 回答
  • 0 关注
  • 233 浏览
慕课专栏
更多

添加回答

举报

0/150
提交
取消
意见反馈 帮助中心 APP下载
官方微信