如何保持長時間運行的Go程序，運行？

Question

我用Go編寫了一個長時間運行的服務器。主程序會執行程序邏輯的幾個例程。之後，主沒有任何用處。一旦主要退出，程序將退出。我現在用來保持程序運行的方法只是對fmt.Scanln（）的簡單調用。我想知道其他人如何避免主要退出。以下是一個基本的例子。這裏可以使用什麼想法或最佳實踐？

我考慮創建一個頻道，並通過在所述頻道上接收延遲主體退出，但是我認爲如果我的所有goroutine在某個時間點變得無效，可能會有問題。注意：在我的服務器（不是例子）中，程序實際上並沒有連接到一個shell，因此無論如何與控制檯交互都沒有意義。目前它可行，但我正在尋找「正確」的方式，假設有一個。

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

Answer 1

Go的運行時的當前設計假定程序員負責檢測何時終止goroutine以及何時終止程序。程序員需要計算goroutines和整個程序的終止條件。程序可以通過調用os.Exit或從main()函數返回以正常方式終止。

通過立即在所述頻道上接收來創建頻道並延遲退出main()是防止main退出的有效方法。但是它並沒有解決檢測何時終止程序的問題。

如果夠程的數量不能main()功能之前計算進入等待換全夠程至終止循環，你需要發送的增量，以便main功能可以跟蹤有多少夠程在航班：

// 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 <- +1 

      go f() 
     } 
    } 
} 

func f() { 
    // When the termination condition for this goroutine is detected, do: 
    goroutineDelta <- -1 
} 

另一種方法是用sync.WaitGroup替換頻道。這種方法的缺點是wg.Add(int)需要調用wg.Wait()之前被調用，因此有必要在main()創建至少1夠程，而隨後的夠程可以在程序的任何部分創建：

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() 
} 

Answer 2

您可以使用Supervisor（http://supervisord.org/）來守護進程。你的函數永遠只是一個運行的過程，它將處理函數main的一部分。您可以使用管理員控制界面啓動/關閉/檢查您的流程。

Answer 3

永遠阻止。例如，

package main 

import (
    "fmt" 
    "time" 
) 

func main() { 
    go forever() 
    select {} // block forever 
} 

func forever() { 
    for { 
     fmt.Printf("%v+\n", time.Now()) 
     time.Sleep(time.Second) 
    } 
} 

Answer 4

這裏永遠是使用渠道

package main 

import (
    "fmt" 
    "time" 
) 

func main() { 
    done := make(chan bool) 
    go forever() 
    <-done // Block forever 
} 

func forever() { 
    for { 
     fmt.Printf("%v+\n", time.Now()) 
     time.Sleep(time.Second) 
    } 
} 

Answer 5

Go的runtime包有一個名爲runtime.Goexit功能，將做的正是你想要的是簡單的塊。在playground

package main 

import (
    "fmt" 
    "runtime" 
    "time" 
) 

func main() { 
    go func() { 
     time.Sleep(time.Second) 
     fmt.Println("Go 1") 
    }() 
    go func() { 
     time.Sleep(time.Second * 2) 
     fmt.Println("Go 2") 
    }() 

    runtime.Goexit() 

    fmt.Println("Exit") 
}