io.Pipe测试
博客专区 > xxbbdd 的博客 > 博客详情
io.Pipe测试
xxbbdd 发表于3个月前
io.Pipe测试
  • 发表于 3个月前
  • 阅读 1
  • 收藏 0
  • 点赞 0
  • 评论 0

腾讯云 新注册用户 域名抢购1元起>>>   

管道会返会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)
}

 

标签: golang
共有 人打赏支持
粉丝 0
博文 11
码字总数 4688
×
xxbbdd
如果觉得我的文章对您有用,请随意打赏。您的支持将鼓励我继续创作!
* 金额(元)
¥1 ¥5 ¥10 ¥20 其他金额
打赏人
留言
* 支付类型
微信扫码支付
打赏金额:
已支付成功
打赏金额: