Golang Bufio writer.Flush()在大缓冲区大小时不写小数据

问题描述 投票:0回答:2

Golang Bufio writer.Flush()在大缓冲区大小时不写小数据(例如4096(标准大小)* 2)

package main
import (
    "log"
    "os"
    "bufio"
)
func main() {
    file, err := os.Create("test")
    defer file.Close()
    w := bufio.NewWriter(file)

    w = bufio.NewWriterSize(
        w,
        4096*2,
    )
    bytesAvailable := w.Available()
    log.Printf("Available %v\n", bytesAvailable)
    bw, _ := w.Write(
      []byte("A"),
    )
    log.Printf("written bytes: %v\n", bw)
    bytesAvailable = w.Available()
    log.Printf("Available: %v\n", bytesAvailable)
    buf := w.Buffered()
    log.Printf("buffered: %d\n", buf)
    err = w.Flush()
    if err != nil {
        log.Fatal(err)
    }
}

当我使用标准大小或我写更多数据时,它按预期工作。

go
2个回答
5
投票

问题是该应用程序有两层bufio编写器:

w := bufio.NewWriter(file)
w = bufio.NewWriterSize(
    w,
    4096*2,
)

一个bufio.Writer包装另一个。应用程序刷新外部bufio.Writer,但是没有代码可以刷新内部bufio.Writer。更改代码以使用单个bufio.Writer,程序将按预期工作。

w := bufio.NewWriterSize(
    file,
    4096*2,
)

1
投票

我相信你错过了对文件指针的Sync()调用,所以文件没有写入文件系统; Flush()只会将缓冲区传递给文件编写器,但是您需要将文件推送到磁盘。

src/os/file_posix.go#L120pkg/bufio/#Writer.Flush

© www.soinside.com 2019 - 2024. All rights reserved.