ループでスキャンする bufio スキャナーのタイムアウトを設定するにはどうすればよいですか?-Golang-php.cn

ループでスキャンする bufio スキャナーのタイムアウトを設定するにはどうすればよいですか?

WBOY

リリース： 2024-02-06 08:05:07

転載

1118 人が閲覧しました

ループでスキャンする bufio スキャナーのタイムアウトを設定するにはどうすればよいですか?

質問内容

golang を使用してプロセスを開始し、出力を監視しています。プロセスは長時間実行されるため、終了するシグナルを送信できる必要があります。

次のコードはほとんどの場合正常に動作します。ただし、何らかの理由でプロセスに出力がない場合があり、for ループが scan() メソッドによってブロックされ、processfinishchan からのメッセージを受信できません。

scan() メソッドのタイムアウトを設定する簡単な方法はありますか?別のゴルーチンで scan() を実行し、別の選択を使用して新しいゴルーチンとタイムアウトチャネルから受信することで解決策を試みましたが、外側の for ループを考慮すると、Will はますます多くのことを実行します。 goroutine は scan によってブロックされますか? p>

// code that start the process...
scanner := bufio.NewScanner(stdout)

for {
    select {
    case <-processFinishChan: // send to this channel to terminate the process
        log.Println("Killing Process")
        err := cmdObject.Process.Kill()
        if err != nil {
            log.Printf("Error Killing: %v", err)
        } else {
            return
        }
    default:
        // default case, read the output of process and send to user.
        if !scanner.Scan() && scanner.Err() == nil {
            // reach EOF
            return
        }
        m := scanner.Bytes()

        WSOutChanHolder.mu.Lock()
        for _, ch := range WSOutChanHolder.data {
            ch <- m
        }
        WSOutChanHolder.mu.Unlock()
    }
}

ログイン後にコピー