为了账号安全,请及时绑定邮箱和手机立即绑定

如何为 GoLang bufio.Writer 设置写入截止日期?

如何为 GoLang bufio.Writer 设置写入截止日期?

Go
皈依舞 2022-11-23 19:47:36

我buffio.Writer在 GoLang 中使用如下。


conn, err := net.Dial("tcp", address) // address is of form ip:port

w := bufio.NewWriter(conn)

w.WriteByte(code) // code is a byte

w.Write(data) // data is a byte buffer

w.Flush()

我试图修改上面的代码,使write()事件有一个截止日期:当截止日期过去时,write()无论成功与否,事件都会返回。


在 GoLang 中,如果conn(连接对象)直接用于使用conn.SetWriteDeadline(time.Now().Add(n * time.Second)). 但是,当我使用bufifo.writer对象时,它本质上是conn缓冲 IO 的包装器,没有 API 来设置截止日期。


虽然它可以使用conn.SetWriteDeadline(time.Now().Add(n * time.Second))和使用conn.Write(b),但它非常低效,因为它不缓冲write事件(因此有很多上下文切换)


在 GoLang 中有没有一种方法可以将缓冲 IO 与writeDeadline()?


查看完整描述

1 回答

?
慕的地10843

TA贡献1534条经验 获得超8个赞

这里有两种情况需要注意。

如果你想要每个write()截止日期,那么就不可能使用缓冲。当您使用缓冲时,实际write()会在缓冲区已满时触发。所以从技术上讲不可能知道你什么时候write()完成。在这种情况下,您实际上是在使用conn.write()并且可以使用conn.SetWriteDeadline(time.Now().Add(n * time.Second)).

在第二种情况下,正如@icza 在评论中提到的那样,您可以在底层conn对象中设置截止日期,并且 buffio.writer() 包装器将遵守此规则。虽然这在语义上是正确的,但它没有提供您想要的网络抽象。


查看完整回答
反对 回复 5天前

添加回答

举报

0/150
提交
取消
意见反馈 帮助中心 APP下载
官方微信