Go管道写端被关闭,为什么?
Golang小白一枚,正在不断学习积累知识,现将学习到的知识记录一下,也是将我的所得分享给大家!而今天这篇文章《Go管道写端被关闭,为什么?》带大家来了解一下##content_title##,希望对大家的知识积累有所帮助,从而弥补自己的不足,助力实战开发!
我刚刚读了一些 go 代码,它执行以下操作:
type someType struct {
...
...
rpipe io.ReadCloser
wpipe io.WriteCloser
}
var inst someType
inst.rpipe, inst.wpipe, _ := os.Pipe()
cmd := exec.Command("some_binary", args...)
cmd.Stdout = inst.wpipe
cmd.Stderr = inst.wpipe
if err := cmd.Start(); err != nil {
....
}
inst.wpipe.Close()
inst.wpipe = nil
some_binary 是一个长时间运行的进程。
- 为什么
inst.wpipe关闭并设置为 nil?如果不关闭的话会发生什么?关闭 inst.wpipe 是否常见/有必要? dup2(pipe_fd[1], 1)是cmd.stdout = inst.wpipe; 的 c 类似物吗? inst.wpipe.close()?
正确答案
该代码是典型的想要读取其他程序生成的输出的程序。 os.Pipe() 函数返回一对连接的 os.file 实体(或者,发生错误时,不应简单地忽略该实体),其中第二个(w 或 wpipe)实体上的写入在第一个实体上显示为可读字节( r / rpipe) 实体。但是——这是第一个问题答案的一半关键——读者如何知道所有作者何时完成写作?
为了让读取器获得 eof 指示,所有拥有或有权访问管道写入端的写入器必须调用 close 操作。通过将管道的写入端传递给我们以 cmd.start() 启动的程序,我们允许该命令访问管道的写入端。当该命令关闭该管道时,具有访问权限的实体之一已关闭该管道。但另一个具有访问权限的实体尚未关闭它:我们拥有写入权限。
要查看 eof,我们必须使用 wpipe.close() 关闭对我们的 wpipe 的访问。所以回答前半部分:
- 为什么
inst.wpipe关闭并设置为 nil?
set-to-nil 部分可能有也可能没有任何功能;您应该检查其余的代码以确定它是否有效。
dup2(pipe_fd[1], 1)是cmd.stdout = inst.wpipe; 的 c 类似物吗? inst.wpipe.close()?
不完全是。 dup2 级别在 posix os 区域中较低,而 cmd.stdout 处于较高(与操作系统无关)级别。 cmd.start() 的 posix 实现将在调用 fork (或等效的东西)之后最终调用 dup2 (或等效的东西)。 inst.wipe.close() 的 posix 等效项是 close(wfd),其中 wfd 是 wpipe 中的 posix 文件编号。
在没有任何更高级别包装的 c 代码中,我们会有类似的内容:
int fds[2];
if (pipe(fds) < 0) ... handle error case ...
pid = fork();
switch (pid) {
case -1: ... handle error ...
case 0: /* child */
if (dup2(fds[1], 1) < 0 || dup2(fds[1], 2) < 0) ... handle error ...
if (execve(prog, args, env) < 0) ... handle error ...
/* NOTREACHED */
default: /* parent */
if (close(fds[1]) < 0) ... handle error ...
... read from fds[0] ...
}
(尽管如果我们足够仔细地检查 close 中的错误,我们可能应该足够仔细地检查 pipe 系统调用是否给我们返回了描述符 0 和 1,或者 1 和 2,或者 2 和 3,在这里,也许我们可以通过确保 0、1 和 2 至少对 /dev/null 开放来更早地处理这个问题。
理论要掌握,实操不能落!以上关于《Go管道写端被关闭,为什么?》的详细介绍,大家都掌握了吧!如果想要继续提升自己的能力,那么就来关注golang学习网公众号吧!
WIN7系统出现0x80070002错误的处理方法
- 上一篇
- WIN7系统出现0x80070002错误的处理方法
- 下一篇
- 当通道关闭时,以接收通道为参数的 goroutine 是否会停止?
-
- Golang · Go问答 | 1天前 |
- Go ColumnTypes 推断动态查询字段的安全用法
- 319浏览 收藏
-
- Golang · Go问答 | 1天前 | Go问答 · Go 错误检查 database/sql Rows.Err
- Go Rows.Err 在迭代结束后的错误检查
- 266浏览 收藏
-
- Golang · Go问答 | 1天前 |
- Go sql.Scan NULL 到字符串失败的字段适配
- 388浏览 收藏
-
- Golang · Go问答 | 1天前 |
- Go Tx.Stmt 复用预处理语句的生命周期
- 154浏览 收藏
-
- Golang · Go问答 | 1天前 |
- Go 事务隔离级别设置未生效的驱动边界
- 165浏览 收藏
-
- Golang · Go问答 | 1天前 |
- Go DB PingContext 启动探活的超时配置
- 438浏览 收藏
-
- Golang · Go问答 | 1天前 |
- Go database/sql Rows 未关闭造成连接耗尽的诊断
- 354浏览 收藏
-
- Golang · Go问答 | 1天前 |
- Go database/sql 连接池 MaxIdleConns 的容量关系
- 478浏览 收藏
-
- Golang · Go问答 | 1天前 |
- Go URL 查询值乱码时的编码排查步骤
- 285浏览 收藏
-
- Golang · Go问答 | 1天前 | Go问答 · Go URL路径 url.JoinPath PathEscape 双斜杠
- Go url.JoinPath 处理双斜杠的路径规则
- 446浏览 收藏
-
- 前端进阶之JavaScript设计模式
- 设计模式是开发人员在软件开发过程中面临一般问题时的解决方案,代表了最佳的实践。本课程的主打内容包括JS常见设计模式以及具体应用场景,打造一站式知识长龙服务,适合有JS基础的同学学习。
- 543次学习
-
- GO语言核心编程课程
- 本课程采用真实案例,全面具体可落地,从理论到实践,一步一步将GO核心编程技术、编程思想、底层实现融会贯通,使学习者贴近时代脉搏,做IT互联网时代的弄潮儿。
- 516次学习
-
- 简单聊聊mysql8与网络通信
- 如有问题加微信:Le-studyg;在课程中,我们将首先介绍MySQL8的新特性,包括性能优化、安全增强、新数据类型等,帮助学生快速熟悉MySQL8的最新功能。接着,我们将深入解析MySQL的网络通信机制,包括协议、连接管理、数据传输等,让
- 500次学习
-
- JavaScript正则表达式基础与实战
- 在任何一门编程语言中,正则表达式,都是一项重要的知识,它提供了高效的字符串匹配与捕获机制,可以极大的简化程序设计。
- 487次学习
-
- 从零制作响应式网站—Grid布局
- 本系列教程将展示从零制作一个假想的网络科技公司官网,分为导航,轮播,关于我们,成功案例,服务流程,团队介绍,数据部分,公司动态,底部信息等内容区块。网站整体采用CSSGrid布局,支持响应式,有流畅过渡和展现动画。
- 485次学习
-
- PubMedQA
- 深入了解PubMedQA生物医学问答数据集,涵盖其核心功能、使用方法及在临床决策、药物研发等场景的应用,助力提升NLP模型性能。
- 268次使用
-
- H2O EvalGPT
- H2O EvalGPT是H2O.ai推出的开源LLM评估平台,提供详细的大模型性能排行榜、行业特定基准测试及A/B测试功能,助您快速选择最适合项目的高性能大语言模型。
- 319次使用
-
- LMArena
- LMArena是加州大学伯克利分校推出的AI模型匿名评测平台。通过盲测投票机制,用户可对比不同大模型回答并生成实时排行榜,助力开发者优化模型及用户选择最佳AI工具。
- 305次使用
-
- HELM
- 深入了解斯坦福推出的HELM(Holistic Evaluation of Language Models)大模型评测体系。本文解析其核心功能、安装配置步骤及应用场景,涵盖准确性、公平性、鲁棒性等多维度指标,助力开发者全面优化语言模型性能。
- 282次使用
-
- MMBench
- MMBench是由上海人工智能实验室等机构联合推出的多模态基准测试平台,提供细粒度能力评估、大规模数据集及VLMEvalKit工具。本文详细介绍其核心功能、安装使用方法及应用场景,助力开发者全面评估多模态模型性能。
- 98次使用
-
- 用Nginx反向代理部署go写的网站。
- 2023-01-17 502浏览
-
- GoLand调式动态执行代码
- 2023-01-13 502浏览
-
- Go tls.GetCertificate 为什么收不到空 ServerName 请求
- 2026-09-27 501浏览
-
- Go sql.Tx提交成功前读取结果导致事务边界混乱的修复方法
- 2026-09-20 501浏览
-
- Go select 用 time.After 做超时有什么资源代价
- 2026-09-10 501浏览
