ringbuffer:ringbuffer是用来替代Go语言的channel,提高海量数据收发的性能

时间:2024-06-12 03:43:54
【文件属性】:

文件名称:ringbuffer:ringbuffer是用来替代Go语言的channel,提高海量数据收发的性能

文件大小:3KB

文件格式:ZIP

更新时间:2024-06-12 03:43:54

Go

ringbuffer ringbuffer是用来替代Go语言的channel,提高海量数据收发的性能。目前只支持一个写。 #####使用方法 ring := ringbuffer.NewRing(100, 1000) // 一个写端 go func() { var wbuf *ringbuffer.Buffer for i := 0; i < 10000; i++ { wbuf = ring.Write(wbuf, i) } ring.Stop(wbuf) }() // 10个读端 var wg sync.WaitGroup for i := 0; i < 10; i++ { wg.Add(1) go func() { defer wg.Done() var ( rbuf *ringbuffer.Buffer e interface{} )


【文件预览】:
ringbuffer-master
----.gitignore(259B)
----ringbuffer.go(3KB)
----README.md(653B)
----LICENSE(1KB)

网友评论