長時間実行しているGoプログラムを実行するにはどうすればよいですか？

Question

私はGoで書かれた長い実行サーバーを持っています。メインは、プログラムのロジックが実行されるいくつかのゴルーチンを起動します。その後、メインは役に立たない。メインが終了すると、プログラムは終了します。私が今プログラムを実行し続けるために使用している方法はfmt.Scanln（）の単純な呼び出しです。私は他の人がどのようにメインから退出するのか知りたいです。以下は基本的な例です。ここではどのようなアイデアやベストプラクティスを使用できますか？

私はチャンネルを作成し、そのチャンネルで受信してメインの出口を遅らせることを検討しましたが、私のゴルーチンがある時点ですべて非アクティブになると問題になるかもしれません。

サイドノート：私のサーバ（例ではありません）では、プログラムは実際にシェルに接続されているわけではないので、とにかくコンソールとやりとりするのは本当に意味がありません。現時点では機能していますが、私は「正しい」方法を探しています。

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のランタイムの現在の設計では、プログラマがいつゴルーチンを終了するのか、いつプログラムを終了するのかを検出することを前提としています。プログラマは、ゴルーチンとプログラム全体の終了条件を計算する必要があります。プログラムは、通常の方法で、os.Exitを呼び出すか、または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

あなたはスーパーバイザー（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

を使用して、簡単なブロックであるゴーの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") 
}