代码在读取命名管道时无限期地阻塞且不产生任何输出

各位小伙伴们，大家好呀！看看今天我又给各位带来了什么文章？本文标题是《代码在读取命名管道时无限期地阻塞且不产生任何输出》，很明显是关于Golang的文章哈哈哈，其中内容主要会涉及到等等，如果能帮到你，觉得很不错的话，欢迎各位多多点评和分享！

我写了一段带有ipc目的的代码。预期的行为是代码从命名管道读取内容并打印字符串（使用 send("log", buff.string())）。首先，我在 goroutine 内打开命名管道“阅读器”，当阅读器打开时，我发送一个信号，表明数据可以写入命名管道（使用 send("datarequest", "")）。这是代码：

var wg sync.waitgroup
wg.add(1)

go func() {
    //reader part
    file, err := os.openfile("tmp/"+os.args[1], os.o_rdonly, os.modenamedpipe)
    if err != nil {
        send("error", err.error())
    }

    var buff bytes.buffer
    _, err = io.copy(&buff, file)

    send("log", buff.string())

    if err != nil {
        send("error", err.error())
    }

    wg.done()
}()

send("datarequest", "")
wg.wait()

这是发送信号时执行的代码：

//writer part
    file, err := os.OpenFile("tmp/" + execID, os.O_WRONLY, 0777)

    if err != nil {
        c <- "[error] error opening file: " + err.Error()
    }

    bytedata, _ := json.Marshal(moduleParameters)
    file.Write(bytedata)

因此，当我尝试复制代码时，我发现代码会无限期地阻塞。我真的不知道为什么会发生这种情况。当我在终端中使用 cat 进行测试时，我确实得到了预期的结果，所以我的问题是如何使用代码获得相同的结果？

编辑

execid 与 os.args[1] 相同

解决方案

编写者应在发送完成后使用 file.Close() 关闭文件。请注意，file.Close() 可能会返回错误。

终于介绍完啦！小伙伴们，这篇关于《代码在读取命名管道时无限期地阻塞且不产生任何输出》的介绍应该让你收获多多了吧！欢迎大家收藏或分享给更多需要学习的朋友吧~golang学习网公众号也会发布Golang相关知识，快来关注吧！