Go simple async message bus.
Contributors:
Want to contribute ? Feel free to send pull requests!
Have problems, bugs, feature ideas? We are using the github issue tracker to manage them.
CPU: 3,3 GHz Intel Core i7
RAM: 16 GB 2133 MHz LPDDR3
➜ message-bus git:(master) ✗ go test -bench=. -cpu=4 -benchmem
goos: darwin
goarch: amd64
BenchmarkBus-4 3000000 534 ns/op 56 B/op 3 allocs/op
BenchmarkBusParallel-4 5000000 313 ns/op 48 B/op 2 allocs/op
BenchmarkBus100-4 100000 14651 ns/op 56 B/op 3 allocs/op
BenchmarkBus100Parallel-4 300000 14130 ns/op 48 B/op 2 allocs/op
BenchmarkBus1000-4 10000 159269 ns/op 56 B/op 3 allocs/op
BenchmarkBus1000Parallel-4 10000 142578 ns/op 48 B/op 2 allocs/op
BenchmarkBusNumCPU-4 1000000 1155 ns/op 56 B/op 3 allocs/op
BenchmarkBusNumCPUParallel-4 2000000 774 ns/op 48 B/op 2 allocs/op
PASS
ok message-bus 23.125spackage main
import (
"fmt"
"github.com/vardius/message-bus"
)
func main() {
queueSize := 100
bus := messagebus.New(queueSize)
var wg sync.WaitGroup
wg.Add(2)
bus.Subscribe("topic", func(v bool) {
defer wg.Done()
fmt.Println(v)
})
bus.Subscribe("topic", func(v bool) {
defer wg.Done()
fmt.Println(v)
})
// Publish block only when the buffer of one of the subscribers is full.
// change the buffer size altering queueSize when creating new messagebus
bus.Publish("topic", true)
wg.Wait()
}This package is released under the MIT license. See the complete license in the package: