Go Queue

A simple importable queue library for Golang.

Example Usage

package main

import (
	"fmt"

	"go.adenix.dev/queue"
)

func main() {
	q := queue.NewWorkerQueue(10, 10)

	for i := 0; i < 100; i++ {
		q.EnqueueBlock(newJob(fmt.Sprintf("Austin %d", i)))
	}

	q.CloseAndWait()
}

func newJob(name string) queue.Job {
	return func() queue.JobResult {
		fmt.Printf("Hello, %s!\n", name)
		return queue.Success
	}
}