長時間実行されているバイトからバッファーへのコピー

Question

私は、数秒ごとに（EOFではない）いくつかのデータを返すように、そしてio.Copyをbytes.Bufferに（また決して終わらないように）行うゴルーチンを長生きしています。何かのように：

var src io.Reader 
var buf bytes.Buffer 

func main() { 
    go io.Copy(&buf, src) 
    // Do stuff. Read from the buffer periodically. 
} 

私が理解できないのは、私がそのバッファから読み込もうとすると、奇妙な結果が出るということです。私がbuf.Bytes()またはioutil.ReadAll(&buf)または何かを呼び出すかどうかは関係ありません、私はちょうどバッファに何度も何度も書き込まれた最初のバイトを見ます。

https://play.golang.org/p/yn0JPrvohV

私の質問は、私が間違って何をやっているのですか？このようにしてbytes.Bufferを使用することができますか（io.Copyと定期的に読んでください）。

Answer 1

io.Copyのbytes.Bufferで発生している書き込みと読み取り呼び出しを同期させることはできません。 Read/Writeメソッドをロックする構造体にbytes.Bufferをラップしても、ReadAllがReadでブロックされている間にCopyがWriteを待機していると、デッドロックになります。手動でコピーを実行し、すべてのアクセスをシリアル化するか、またはio.Pipeで読み取りと書き込みを分離する必要があります。

FIFO（io.Pipe）を使用して読み込みと書き込みを同期させる場合は、先頭の末尾に余分なロックやチャネルは必要ありません。io.Reader

func read(r io.Reader) { 
    buf := make([]byte, 1024) 
    pos := 0 
    lastPrint := time.Now() 
    for { 
     n, err := r.Read(buf[pos:]) 
     if n > 0 { 
      pos += n 
     } 

     if pos >= len(buf) || time.Since(lastPrint) > 125*time.Millisecond && pos > 0 { 
      fmt.Println("read:", buf[:pos]) 
      lastPrint = time.Now() 
      pos = 0 
     } 

     if err != nil { 
      fmt.Println(err) 
      break 
     } 
    } 

    if pos > 0 { 
     fmt.Println("read:", buf[:pos]) 
    } 
} 

func main() { 
    pr, pw := io.Pipe() 
    go func() { 
     io.Copy(pw, &trickle{}) 
     pw.Close() 
    }() 
    read(pr) 
} 

https://play.golang.org/p/8NeV3v0LOU