尝试在Go语言中使用goroutines写文件。

huangapple go评论71阅读模式
英文:

Trying to test write file from goroutines in Go

问题

好的,以下是翻译好的内容:

嗯,我的代码的一部分在没有使用方法的情况下工作,我正在尝试测试将文本追加到文件并从goroutine中读取,但我在尝试写入时卡住了。

有什么问题吗?文件已创建,但我无法将文本追加到其中,可能是一些明显的问题,但似乎我看不见,也许我在理解某些语言概念方面出错了...

package main

import (
	"bufio"
	"fmt"
	"os"
	"sync"
	"time"
)

var w sync.WaitGroup

type Buffer struct {
	F *os.File
}

func (buff *Buffer) Open(pathName string) (err error) {
	buff.F, err = os.OpenFile(pathName, os.O_APPEND|os.O_CREATE, 0666)
	if err != nil {
		return
	}
	fmt.Println("Open() ok")
	return nil
}
func (buff *Buffer) Close() (err error) {
	err = buff.F.Close()
	if err != nil {
		return
	}
	fmt.Println("Close() ok")
	return nil
}
func (buff *Buffer) Push(data string) (err error) {
	w := bufio.NewWriter(buff.F)
	_, err = fmt.Fprintf(w, "data=%s", data)
	if err != nil {
		return
	}
	w.Flush()
	fmt.Println("Push() ok")
	return nil
}
func checkErr(err error) {
	if err != nil {
		fmt.Println(err.Error())
	}
}
func worker() {
	var err error
	buffer := new(Buffer)
	err = buffer.Open("test")
	checkErr(err)
	err = buffer.Push("data\n")
	checkErr(err)
	time.Sleep(5 * time.Second)
	err = buffer.Close()
	checkErr(err)
	w.Done()
}
func main() {
	w.Add(2)
	go worker()
	go worker()
	w.Wait()
}

谢谢!

英文:

Well, part of my code was working without a method approach, I'm trying to test
append text to a file and reading from goroutines, but I'm stuck here trying to
write it.

What is wrong? the file is created, but I can't append text to it, maybe something obvious, but seems I'm blind, maybe I'm failing understanding some language concepts...

package main
import (
"bufio"
"fmt"
"os"
"sync"
"time"
)
var w sync.WaitGroup
type Buffer struct {
F *os.File
}
func (buff *Buffer) Open(pathName string) (err error) {
buff.F, err = os.OpenFile(pathName, os.O_APPEND|os.O_CREATE, 0666)
if err != nil {
return
}
fmt.Println("Open() ok")
return nil
}
func (buff *Buffer) Close() (err error) {
err = buff.F.Close()
if err != nil {
return
}
fmt.Println("Close() ok")
return nil
}
func (buff *Buffer) Push(data string) (err error) {
w := bufio.NewWriter(buff.F)
_, err = fmt.Fprintf(w, "data=%s", data)
if err != nil {
return
}
w.Flush()
fmt.Println("Push() ok")
return nil
}
func checkErr(err error) {
if err != nil {
fmt.Println(err.Error())
}
}
func worker() {
var err error
buffer := new(Buffer)
err = buffer.Open("test")
checkErr(err)
err = buffer.Push("data\n")
checkErr(err)
time.Sleep(5 * time.Second)
err = buffer.Close()
checkErr(err)
w.Done()
}
func main() {
w.Add(2)
go worker()
go worker()
w.Wait()
}

Thanks

答案1

得分: 3

像这样打开文件:

buff.F, err = os.OpenFile(pathName, os.O_WRONLY|os.O_APPEND|os.O_CREATE, 0666)

写入标志是必需的以便写入文件。

你错过了写入错误,因为忽略了从bufio Flush返回的值。将Push更改为:

func (buff *Buffer) Push(data string) (err error) {
w := bufio.NewWriter(buff.F)
_, err = fmt.Fprintf(w, "data=%s", data)
if err != nil {
return
}
err = w.Flush()
if err != nil {
return err
}
fmt.Println("Push() ok")
return nil
}

为了在不与其他推送混合的情况下清晰地追加数据,必须使用单个调用文件的Write方法来写入数据。使用bytes.Buffer而不是bufio.Writer,以确保对文件的Write方法进行单个调用:

func (buff *Buffer) Push(data string) (err error) {
var b bytes.Buffer
_, err = fmt.Fprintf(&b, "data=%s", data)
if err != nil {
return
}
_, err := buff.F.Write(b.Bytes())
if err != nil {
return err
}
fmt.Println("Push() ok")
return nil
}
英文:

Open the file like this:

buff.F, err = os.OpenFile(pathName, os.O_WRONLY|os.O_APPEND|os.O_CREATE, 0666)

The write flag is required to write to the file.

You missed the write error because the return from bufio Flush is ignored. Change Push to:

func (buff *Buffer) Push(data string) (err error) {
w := bufio.NewWriter(buff.F)
_, err = fmt.Fprintf(w, "data=%s", data)
if err != nil {
return
}
err = w.Flush()
if err != nil {
return err
}
fmt.Println("Push() ok")
return nil
}

To cleanly append data without intermixing with other pushes, the data must be written with a single call to the file Write method. Use a bytes.Buffer instead of a bufio.Writer to ensure a single call to the file Write method:

func (buff *Buffer) Push(data string) (err error) {
var b bytes.Buffer
_, err = fmt.Fprintf(&b, "data=%s", data)
if err != nil {
return
}
_, err := buff.F.Write(b.Bytes())
if err != nil {
return err
}
fmt.Println("Push() ok")
return nil
}

huangapple
  • 本文由 发表于 2014年10月3日 08:58:41
  • 转载请务必保留本文链接:https://go.coder-hub.com/26171854.html
匿名

发表评论

匿名网友

:?: :razz: :sad: :evil: :!: :smile: :oops: :grin: :eek: :shock: :???: :cool: :lol: :mad: :twisted: :roll: :wink: :idea: :arrow: :neutral: :cry: :mrgreen:

确定