dqftyn1717 2017-12-18 19:31
浏览 1166
已采纳

大缓冲区大小时,Golang Bufio编写器.Flush()不会写入小数据

Golang Bufio writer .Flush() does not write small data when big buffer size (example 4096(standard size)*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
", bytesAvailable)
    bw, _ := w.Write(
      []byte("A"),
    )
    log.Printf("written bytes: %v
", bw)
    bytesAvailable = w.Available()
    log.Printf("Available: %v
", bytesAvailable)
    buf := w.Buffered()
    log.Printf("buffered: %d
", buf)
    err = w.Flush()
    if err != nil {
        log.Fatal(err)
    }
}

When I use the standard size or I write more data it works as expected.

  • 写回答

2条回答 默认 最新

  • dongyuan9292 2017-12-18 19:47
    关注

    The problem is that the application has two layers of bufio writers:

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

    One bufio.Writer wraps the other. The application flushes the outer bufio.Writer, but there's no code that flushes the inner bufio.Writer. Change the code to use a single bufio.Writer and the program will work as expected.

    w := bufio.NewWriterSize(
        file,
        4096*2,
    )
    
    本回答被题主选为最佳回答 , 对您是否有帮助呢?
    评论
查看更多回答(1条)

报告相同问题?

悬赏问题

  • ¥15 基于卷积神经网络的声纹识别
  • ¥15 Python中的request,如何使用ssr节点,通过代理requests网页。本人在泰国,需要用大陆ip才能玩网页游戏,合法合规。
  • ¥100 为什么这个恒流源电路不能恒流?
  • ¥15 有偿求跨组件数据流路径图
  • ¥15 写一个方法checkPerson,入参实体类Person,出参布尔值
  • ¥15 我想咨询一下路面纹理三维点云数据处理的一些问题,上传的坐标文件里是怎么对无序点进行编号的,以及xy坐标在处理的时候是进行整体模型分片处理的吗
  • ¥15 CSAPPattacklab
  • ¥15 一直显示正在等待HID—ISP
  • ¥15 Python turtle 画图
  • ¥15 stm32开发clion时遇到的编译问题