Fly multi-producer / multi-consumer channels for Go

A flyline buffer works similar to a standard Go channel with the following features:

• It has a sync method. That means, you can wait for all after close buffer.
• It is lock-free and thread-safe.
• By default, it does not have a cap, you can use send filter to implement it.

To start using flyline, install Go and run go get:

$ go get github.com/pharosnet/flyline

This will retrieve the library.

It's easily to use, like standard Go channel.

// buffer.go
package main

import (
	"github.com/pharosnet/flyline"
	"time"
	"context"
)

func main() {
	buf := flyline.NewArrayBuffer(1024*16)
	buf.Send(time.Now())
	value, ok := buf.Recv()
	recvTime := time.Time{}
	flyline.ValueScan(value, &recvTime)
	println(recvTime)
	// close buffer
	buf.Close()
	// change ctx to timeout, if sync with timeout. 
	buf.Sync(context.Background())
}

$ go run buffer.go 

// buffer.go
package main

import (
	"github.com/pharosnet/flyline"
	"time"
	"context"
)

func main() {
	buf := flyline.NewQueueBuffer()
	buf.Send(time.Now())
	value, ok := buf.Recv()
	recvTime := time.Time{}
	flyline.ValueScan(value, &recvTime)
	println(recvTime)
	// close buffer
	buf.Close()
	// change ctx to timeout, if sync with timeout. 
	buf.Sync(context.Background())
}

$ go run buffer.go 

Each of the following benchmark tests sends an incrementing sequence message from one goroutine to another. The receiving goroutine asserts that the message is received is the expected incrementing sequence value. Any failures cause a panic. Unless otherwise noted, all tests were run using GOMAXPROCS=2.

• CPU: Intel Core i5 @ 2.70 Ghz
• Operation System: OS X 10.13.4
• Go Runtime: Go 1.10.0
• Go Architecture: amd64

Ryougi Nevermore @ryougi

flyline source code is available under the GPL-3 License.