如何在Golang中为io.PipeRaeder执行非阻塞Read()

7gs2gvoe 于 12个月前发布在 Go

关注(0)|答案(1)|浏览(99)

我有以下代码。可执行程序将在5秒后向stdout发送一些文本。因此，在接收数据之前，in.ReadLine（）将阻塞。如何为ReadLine（）设置超时或以非阻塞方式设置？

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

来源：https://stackoverflow.com/questions/76824660/how-to-do-non-blocking-read-for-io-piperaeder-in-golang

1条答案

按热度按时间

nhaq1z211#

谢谢你的评论。我自己想出来的。

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

}

赞(0）回复(0）举报 12个月前

我来回答

如何在Golang中为io.PipeRaeder执行非阻塞Read()

1条答案

相关问题

热门标签

最新问答