如何最好地保持一个长时间运行的 Go 程序运行？

哈喽！大家好，很高兴又见面了，我是golang学习网的一名作者，今天由我给大家带来一篇《如何最好地保持一个长时间运行的 Go 程序运行？》，本文主要会讲到golang等等知识点，希望大家一起学习进步，也欢迎大家关注、点赞、收藏、转发! 下面就一起来看看吧！

问题内容

我有一个用 Go 编写的长时间运行的服务器。Main 触发了几个执行程序逻辑的 goroutine。在那之后， main 没有任何用处。一旦 main 退出，程序将退出。我现在用来保持程序运行的方法只是对 fmt.Scanln() 的简单调用。我想知道其他人如何阻止 main 退出。下面是一个基本的例子。这里可以使用哪些想法或最佳实践？

我考虑过创建一个通道并通过在所述通道上接收来延迟 main 的退出，但我认为如果我所有的 goroutine 在某个时候都变得不活动，这可能会出现问题。

旁注：在我的服务器（不是示例）中，程序实际上并没有连接到外壳运行，因此无论如何与控制台交互都没有意义。现在它有效，但我正在寻找“正确”的方式，假设有一个。

package main

import (
    "fmt"
    "time"
)

func main() {
    go forever()
    //Keep this goroutine from exiting
    //so that the program doesn't end.
    //This is the focus of my question.
    fmt.Scanln()
}

func forever() {
    for ; ; {
    //An example goroutine that might run
    //indefinitely. In actual implementation
    //it might block on a chanel receive instead
    //of time.Sleep for example.
        fmt.Printf("%v+\n", time.Now())
        time.Sleep(time.Second)
    }
}

正确答案

Go 运行时的当前设计假设程序员负责检测何时终止 goroutine 以及何时终止程序。程序员需要计算 goroutine 和整个程序的终止条件。程序可以通过调用os.Exit或从main()函数返回以正常方式终止。

通过在该通道上立即接收来创建通道并延迟退出main()是防止main退出的有效方法。但它并没有解决检测何时终止程序的问题。

如果在函数进入 wait-for-all-goroutines-to-terminate 循环之前无法计算 goroutines 的数量，则main()需要发送 deltas 以便main函数可以跟踪有多少 goroutines 正在运行：

// Receives the change in the number of goroutines
var goroutineDelta = make(chan int)

func main() {
    go forever()

    numGoroutines := 0
    for diff := range goroutineDelta {
        numGoroutines += diff
        if numGoroutines == 0 { os.Exit(0) }
    }
}

// Conceptual code
func forever() {
    for {
        if needToCreateANewGoroutine {
            // Make sure to do this before "go f()", not within f()
            goroutineDelta 
<p>另一种方法是将通道替换为<a target='_blank'  href='https://www.17golang.com/gourl/?redirect=MDAwMDAwMDAwML57hpSHp6VpkrqbYLx2eayza4KafaOkbLS3zqSBrJvPsa5_0Ia6sWuR4Juaq6t9nq5roGCUgXpusdyfppZkr83GoZTZmpaup4SZcqK8q2muypBtmnyyh5C-utJohmWB28iMcs6B3LGjgZiCnLB2l6uzgI1lfoCKsbK3yqGNrICas3icmJK3sWyR4H2qvIaGnrOmhWU' rel='nofollow'><code>sync.WaitGroup</code></a>.
这种方法的一个缺点是<code>wg.Add(int)</code>需要在调用之前调用<code>wg.Wait()</code>，因此需要在其中创建至少 1 个
goroutine，<code>main()</code>而后续的 goroutine 可以在程序的任何部分创建：</p>
<pre class="brush:go;toolbar:false">var wg sync.WaitGroup

func main() {
    // Create at least 1 goroutine
    wg.Add(1)
    go f()

    go forever()
    wg.Wait()
}

// Conceptual code
func forever() {
    for {
        if needToCreateANewGoroutine {
            wg.Add(1)
            go f()
        }
    }
}

func f() {
    // When the termination condition for this goroutine is detected, do:
    wg.Done()
}

理论要掌握，实操不能落！以上关于《如何最好地保持一个长时间运行的 Go 程序运行？》的详细介绍，大家都掌握了吧！如果想要继续提升自己的能力，那么就来关注golang学习网公众号吧！