文档章节

io.Pipe测试

x
 xxbbdd
发布于 2017/09/09 16:39
字数 90
阅读 8
收藏 0

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

 

© 著作权归作者所有

共有 人打赏支持
上一篇: 指针传递测试
下一篇: log测试
x
粉丝 0
博文 14
码字总数 4734
作品 0
私信 提问
beego 1.4.2 版本发布,Go 应用框架

让大家久等了,这个版本新功能和bugfix都挺多,但是我还是只更新了一个小版本,等着Go1.4跟上来,打算和Go的版本去同步。 新功能: 增加了SQL构造器,参考了ZEND框架的ORM Controller获取参数...

astaxie
2014/11/05
2.6K
8

没有更多内容

加载失败,请刷新页面

加载更多
iOS 官方文档

https://developer.apple.com/library/prerelease/content/navigation/#section=Platforms&topic=iOS...

walking_yxf
15分钟前
2
0
使用Mycat实现MySQL数据库的读写分离

前提准备 1.一台CentOS机器 2.Mycat安装包 (http://www.mycat.io/) 安装使用 1.解压Mycat的安装包到/user/local/下 2.设置mycat的环境变量 vi /etc/profile 3.使配置文件立即生效 source /...

吴伟祥
16分钟前
2
0
Aries数据库事务Recovery算法

背景知识 本文是一篇关于(分布式)数据库的文章,在开始阐述Aries是什么之前,需要先交代几个常识性的概念,这些概念对后文引出Aries显得尤为重要。 数据库体系结构 图1大致描述了一个(分布...

黑客画家
19分钟前
2
0
Rxjava Backpressure 32

原文:https://github.com/Froussios/Intro-To-RxJava/blob/master/Part 4 - Concurrency/4. Backpressure.md Rx将事件从管道的一端引导到另一端,在每一端发生的行动可能非常不同。当生产者...

woshixin
19分钟前
2
0
IDEA-Create Git Repository

1、概述 idea 开发完毕的项目没有及时的关联gitlab,如果整体项目关联gitlab。 2、干 2.1 gitlab 创建项目 2.2 idea 1、IDEA 点击 -> VCS -> import into version control -> create git re......

来来来来来
23分钟前
2
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部