So führen Sie nicht blockierendes Read() auf io.PipeRaeder in Golang durch

In Golang ist io.PipeReader ein häufig verwendeter Reader, aber seine Read()-Methode blockiert die Ausführung des Programms, wenn keine Daten zum Lesen vorhanden sind. Wie implementiert man also das nicht blockierende Lesen von io.PipeReader? Der PHP-Editor Xiaoxin bietet Ihnen eine Lösung. Durch die Verwendung von Select und Goroutine können wir ein nicht blockierendes Lesen von io.PipeReader erreichen und so die Reaktionsfähigkeit und Parallelität des Programms verbessern. Im Folgenden wird die Implementierung dieser Funktion im Detail vorgestellt und Beispielcode angegeben.

Frageninhalt

Ich habe den folgenden Code. Nach 5 Sekunden sendet die ausführbare Datei Text an stdout. Daher blockiert in.readline(), bis Daten empfangen werden. Wie kann ich ein Timeout für readline() festlegen oder es nicht blockierend ausführen?

package main

import (
    "bufio"
    "fmt"
    "io"
    "os/exec"
)

func main() {
    cmd := exec.Command("/path/to/executable")

    stdoutReader, stdoutWriter := io.Pipe()

    cmd.Stdout = stdoutWriter

    cmd.Start()

    in := bufio.NewReader(stdoutReader)
    b, _, _ := in.ReadLine()

    fmt.Println(string(b))
}

Lösung

Danke für deinen Kommentar. Ich verstehe.

package main

import (
    "bufio"
    "fmt"
    "io"
    "os/exec"
    "time"
)

func main() {
    ch := make(chan []byte)
    cmd := exec.Command("/path/to/executable")
    stdoutReader, stdoutWriter := io.Pipe()

    cmd.Stdout = stdoutWriter

    if err := cmd.Start(); err != nil {
        return
    }

    in := bufio.NewReader(stdoutReader)

    go func() {
        b, _, _ := in.ReadLine()
        ch <- b
    }()

    complete := false
    for !complete {
        select {
        case s := <-ch:
            fmt.Println(string(s))
            complete = true
        case <-time.After(time.Second * 5):
            fmt.Println("timeout")
            complete = true
        }
    }

}

Das obige ist der detaillierte Inhalt vonSo führen Sie nicht blockierendes Read() auf io.PipeRaeder in Golang durch. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!