開かれたパイプを閉じるためにgolangを強制する方法

Question

私はスクリプトの長い出力を処理してデータを見つけなければなりません。このデータは、出力のほぼ初めに位置する可能性が最も高いです。データが見つかったら、出力をもう処理する必要はなく、終了することができます。

exec.Cmdには開かれたコマンドを閉じる機能がないため、出力処理を停止できないという問題があります。ここで

は、いくつかの単純化されたコード（エラーハンドリングがommitedた）次のとおりです。

func processOutput(r *bufio.Reader)(){ 
    for { 
     line, _, err := r.ReadLine() 
     if some_condition_meet { 
     break 
     } 
     ...... 
    } 
    return 
} 

func execExternalCommand(){ 
    cmdToExecute := "......" 
    cmd := exec.Command("bash", "-c", cmdToExecute) 
    output, _ := cmd.StdoutPipe() 

    cmd.Start() 
    r := bufio.NewReader(output) 
    go processOutput(r) 
    cmd.Wait() 
    return 
} 

私はcmdを停止するprocessOutput機能で最後に何をすべきでしょうか？多分それを解決する別の方法があります。

おかげ

Answer 1

現状では、受信するすべてのbufio.Readerですので、あなたがprocessOutputからこれを行うことはできません。フォークされたプロセスで何かを行うには、exec.Cmdを渡す必要があります。

フォークされたプロセスを強制終了するには、シグナルを送信します（例：cmd.Process.Kill()またはcmd.Process.Signal(os.SIGINT)）。 exec.Cmdおよびos.Processに関するドキュメントを参照してください。

Answer 2

おそらく、例えば「context」を使用することができます場合は

package main 

import (
    "bufio" 
    "context" 
    "os/exec" 
) 

func processOutput(r *bufio.Reader, cancel context.WithCancel) { 
    for { 
     line, _, err := r.ReadLine() 
     if some_condition_meet { 
      break 
     } 
    } 
    cancel() 
    return 
} 

func main() { 
    ctx, cancel := context.WithCancel(context.Background()) 
    defer cancel() 
    cmdToExecute := "......" 
    cmd := exec.CommandContext(ctx, "bash", "-c", cmdToExecute) 
    output, _ := cmd.StdoutPipe() 

    cmd.Start() 
    r := bufio.NewReader(output) 
    go processOutput(r, cancel) 
    cmd.Wait() 
    return 
} 

はこれが（例はこちらから取られる：https://golang.org/src/os/exec/example_test.go）に仕事ができるのタイムアウトで終了する必要が

func ExampleCommandContext() { 
    ctx, cancel := context.WithTimeout(context.Background(), 100*time.Millisecond) 
    defer cancel() 

    if err := exec.CommandContext(ctx, "sleep", "5").Run(); err != nil { 
    // This will fail after 100 milliseconds. The 5 second sleep 
    // will be interrupted. 
    } 
    } 

基本を単に睡眠を使用して1秒後に閉じる例：https://play.golang.org/p/gIXKuf5Oga