管道会返会Reader和Writer。只有把所有数据读光了才会再写。
package main
import (
"io"
"fmt"
"time"
)
func test() {
r,w := io.Pipe()
go func(r *io.PipeReader) {
for i:=0; i < 10; i++ {
a := make([]byte, 1)
r.Read(a)
fmt.Println(a)
}
}(r)
go func(w *io.PipeWriter) {
for i :=0; i<10; i++ {
var a[] byte
a = append(a, byte(i))
a = append(a, byte(i))
w.Write(a)
time.Sleep(1*time.Second)
}
}(w)
}
func main() {
test()
time.Sleep(1000*time.Second)
}
