- Java锁的逻辑(结合对象头和ObjectMonitor)
- 还在用饼状图?来瞧瞧这些炫酷的百分比可视化新图形(附代码实现)⛵
- 自动注册实体类到EntityFrameworkCore上下文,并适配ABP及ABPVNext
- 基于Sklearn机器学习代码实战
io.ReadAtLeast 函数是Go标准库提供的一个非常好用的函数,能够指定从数据源最少读取到的字节数。本文我们将从 io.ReadAtLeast 函数的基本定义出发,讲述其基本使用和实现原理,以及一些注意事项,基于此完成对 io.ReadAtLeast 函数的介绍.
io.ReadAtLeast 函数用于从读取器( io.Reader )读取至少指定数量的字节数据到缓冲区中。函数定义如下
func ReadAtLeast(r Reader, buf []byte, min int) (n int, err error)
其中 r 是数据源,从它读取数据,而 buf 是用于接收读取到的数据的字节切片, min 是要读取的最小字节数。 io.ReadAtLeast 函数会尝试从读取器中最少读取 min 个字节的数据,并将其存储在 buf 中.
下面是一个示例代码,演示如何使用 io.ReadAtLeast 函数从标准输入读取至少 5 个字节的数据:
package main
import (
"fmt"
"io"
"os"
)
func main() {
buffer := make([]byte, 10)
n, err := io.ReadAtLeast(os.Stdin, buffer, 5)
if err != nil {
fmt.Println("读取过程中发生错误:", err)
return
}
fmt.Printf("成功读取了 %d 个字节:%s\n", n, buffer)
}
在这个例子中,我们创建了一个长度为 10 的字节切片 buffer ,并使用 io.ReadAtLeast 函数从标准输入读取至少 5 个字节的数据到 buffer 中。下面是一个可能的输出,具体如下
hello,world
成功读取了 10 个字节:hello,worl
这里其指定 min 为5,也就是最少读取5个字节的数据,此时调用 io.ReadAtLeast 函数一次性读取到了10个字节的数据,此时也满足要求。这里也间接说明了 io.ReadAtLeast 只保证最少要读取 min 个字节的数据,但是并不限制更多数据的读取.
在了解了 io.ReadAtLeast 函数的基本定义和使用后,这里我们来对 io.ReadAtLeast 函数的实现来进行基本的说明,加深对 io.ReadAtLeast 函数的理解.
其实 io.ReadAtLeast 的实现非常简单,其定义一个变量 n , 保存了读取到的字节数,然后不断调用数据源Reader中的 Read 方法读取数据,然后自增变量 n 的值,直到 n 大于 最小读取字节数为止。下面来看具体代码的实现
func ReadAtLeast(r Reader, buf []byte, min int) (n int, err error) {
// 传入的缓冲区buf长度 小于 最小读取字节数min的值,此时直接返回错误
if len(buf) < min {
return 0, ErrShortBuffer
}
// 在 n < min 时,不断调用Read方法读取数据
// 最多读取 len(buf) 字节的数据
for n < min && err == nil {
var nn int
nn, err = r.Read(buf[n:])
// 自增 n 的值
n += nn
}
if n >= min {
err = nil
} else if n > 0 && err == EOF {
// 读取到的数据字节数 小于 min值,同时数据已经全部读取完了,此时返回 ErrUnexpectedEOF
err = ErrUnexpectedEOF
}
return
}
从上面 io.ReadAtLeast 的实现可以看出来,如果一直没有读取到指定数量的数据,同时也没有发生错误,将一直等待下去,直到读取到至少指定数量的字节数据,或者遇到错误为止。下面举个代码示例来展示下效果
func main() {
buffer := make([]byte, 5)
n, err := io.ReadAtLeast(os.Stdin, buffer, 5)
if err != nil {
fmt.Println("读取过程中发生错误:", err)
return
}
fmt.Printf("成功读取了 %d 个字节:%s\n", n, buffer)
}
在上面代码的例子中,会调用 io.ReadAtLeast 函数从标准输入中读取 5 个字节的数据,如果标准输入一直没有输够5个字节,此时这个函数将会一直等待下去。比如下面的这个输入,首先输入了 he 两个字符,然后回车,由于还没有达到5个字符,此时 io.ReadAtLeast 函数一直不会返回,只有再输入 llo 这几个字符后,才满足5个字符,才能够继续执行,所以在使用 io.ReadAtLeast 函数时,需要注意无限等待的情况.
he
llo
成功读取了 5 个字节:he
ll
buf
的大小足够容纳至少 min
个字节的数据 在调用 io.ReadAtLeast 函数时,需要保证缓冲区 buf 的大小需要满足 min ,如果缓冲区的大小比 min 参数还小的话,此时将永远满足不了 最少读取 min 个字节数据的要求.
从上面 io.ReadAtLeast 的实现可以看出来,如果其发现 buf 的长度小于 min ,其也不会尝试去读取数据,其会直接返回一个 ErrShortBuffer 的错误,下面通过一个代码展示下效果
func main() {
buffer := make([]byte, 3)
n, err := io.ReadAtLeast(os.Stdin, buffer, 5)
if err != nil {
fmt.Println("读取过程中发生错误:", err)
return
}
fmt.Printf("成功读取了 %d 个字节:%s\n", n, buffer)
}
比如上述函数中,指定的 buffer 的长度为3,但是 io.ReadAtLeast 要求最少读取5个字节,此时 buffer 并不能容纳5个字节的数据,此时将会直接 ErrShortBuffer 错误,如下
读取过程中发生错误: short buffer
io.ReadAtLeast 函数是Go语言标准库提供的一个工具函数,能够从数据源读取至少指定数量的字节数据到缓冲区中。 我们先从 io.ReadAtLeast 函数的基本定义出发,之后通过一个简单的示例,展示如何使用 io.ReadAtLeast 函数实现至少读取指定字节数据.
接着我们讲述了 io.ReadAtLeast 函数的实现原理,其实就是不断调用源Reader的Read方法,直接读取到的数据数满足要求.
在注意事项方面,则强调了调用 io.ReadAtLeast 可能出现无限等待的问题,以及需要确保 buf 的大小足够容纳至少 min 个字节的数据.
基于此,完成了对 io.ReadAtLeast 函数的介绍,希望对你有所帮助.
最后此篇关于一文了解io.ReadAtLeast函数的文章就讲到这里了,如果你想了解更多关于一文了解io.ReadAtLeast函数的内容请搜索CFSDN的文章或继续浏览相关文章,希望大家以后支持我的博客! 。
我开始在 Ethereum blockchain 上了解如何开发智能合约以及如何写 web-script用于与智能合约交互(购买、销售、统计......)我得出了该怎么做的结论。我想知道我是否正确理解
我正在 UIView 中使用 CATransform3DMakeRotation,并且我正在尝试进行 45º,变换就像向后放置一样: 这是我拥有的“代码”,但显然没有这样做。 CATransform3
我目前正在测试 WebRTC 的功能,但我有一些脑逻辑问题。 WebRTC 究竟是什么? 我只读了“STUN”、“P2P”和其他...但是在技术方面什么是正确的 WebRTC(见下一个) 我需要什么
我在看 DelayedInit在 Scala in Depth ... 注释是我对代码的理解。 下面的 trait 接受一个非严格计算的参数(由于 => ),并返回 Unit .它的行为类似于构造函数
谁能给我指出一个用图片和简单的代码片段解释 WCF 的资源。我厌倦了谷歌搜索并在所有搜索结果中找到相同的“ABC”文章。 最佳答案 WCF 是一项非常复杂的技术,在我看来,它的文档记录非常少。启动和运
我期待以下 GetArgs.hs打印出传递给它的参数。 import System.Environment main = do args main 3 4 3 :39:1: Coul
private int vbo; private int ibo; vbo = glGenBuffers(); ibo = glGenBuffers(); glBindBuffer(GL_ARRAY_
我正在尝试一个 for 循环。我添加了一个 if 语句以在循环达到 30 时停止循环。 我见过i <= 10将运行 11 次,因为循环在达到 10 次时仍会运行。 如果有设置 i 的 if 语句,为什
我正在尝试了解 WSGI 的功能并需要一些帮助。 到目前为止,我知道它是一种服务器和应用程序之间的中间件,用于将不同的应用程序框架(位于服务器端)与应用程序连接,前提是相关框架具有 WSGI 适配器。
我是 Javascript 的新手,我正在尝试绕过 while 循环。我了解它们的目的,我想我了解它们的工作原理,但我在使用它们时遇到了麻烦。 我希望 while 值自身重复,直到两个随机数相互匹配。
我刚刚偶然发现Fabric并且文档并没有真正说明它是如何工作的。 我有根据的猜测是您需要在客户端和服务器端都安装它。 Python 代码存储在客户端,并在命令运行时通过 Fabric 的有线协议(pr
我想了解 ConditionalWeakTable .和有什么区别 class ClassA { static readonly ConditionalWeakTable OtherClass
关闭。这个问题需要更多focused .它目前不接受答案。 想改善这个问题吗?更新问题,使其仅关注一个问题 editing this post . 5年前关闭。 Improve this questi
我还没有成功找到任何可以引导我理解 UIPickerView 和 UIPickerView 模型的好例子。有什么建议吗? 最佳答案 为什么不使用默认的 Apple 文档示例?这是来自苹果文档的名为 U
我在看foldM为了获得关于如何使用它的直觉。 foldM :: Monad m => (a -> b -> m a) -> a -> [b] -> m a 在这个简单的例子中,我只返回 [Just
答案What are _mm_prefetch() locality hints?详细说明提示的含义。 我的问题是:我想要哪一个? 我正在处理一个被重复调用数十亿次的函数,其中包含一些 int 参数。
我一直在读这个article了解 gcroot 模板。我明白 gcroot provides handles into the garbage collected heap 然后 the handle
提供了一个用例: 流处理架构;事件进入 Kafka,然后由带有 MongoDB 接收器的作业进行处理。 数据库名称:myWebsite集合:用户 并且作业接收 users 集合中的 user 记录。
你好 我想更详细地了解 NFS 文件系统。我偶然发现了《NFS 图解》这本书,不幸的是它只能作为谷歌图书提供,所以有些页面丢失了。有人可能有另一个很好的资源,这将是在较低级别上了解 NFS 的良好开始
我无法理解这个问题,哪个更随机? rand() 或: rand() * rand() 我发现这是一个真正的脑筋急转弯,你能帮我吗? 编辑: 凭直觉,我知道数学答案是它们同样随机,但我忍不住认为,如果您
我是一名优秀的程序员,十分优秀!