Multi backend queues for Golang
go get github.com/nickalie/go-queue
A generic Queue[T] wrapper provides compile-time type safety on top of any backend:
q := queue.New[string]("messages")
if err := q.Put("hello"); err != nil {
log.Fatal(err)
}
msg, err := q.Get() // msg is a string, no pointers or type assertions
if err != nil {
log.Fatal(err)
}
fmt.Println(msg)package main
import (
"fmt"
"github.com/nickalie/go-queue"
"time"
)
func main() {
for i := 0; i < 5; i++ {
go consumer(i + 1)
}
producer()
}
func producer() {
i := 0
for {
i++
queue.Put("messages", fmt.Sprintf("message %d", i))
time.Sleep(time.Second)
}
}
func consumer(index int) {
for {
var message string
queue.Get("messages", &message)
fmt.Printf("Consumer %d got a message: %s\n", index, message)
time.Sleep(2 * time.Second)
}
}