Task Queues for Go

A Go package that provides queues for tasks to be handled sequentially.

Installation

go get github.com/jirenius/taskqueue

Usage

TaskQueue

    // Create a TaskQueue with a queue cap of 5.
    tq := taskqueue.NewTaskQueue(5)

    // Add callbacks to be called sequentially in the queued order.
    tq.Do(func() { fmt.Println("First") })
    tq.Do(func() { fmt.Println("Second") })

    // Add a callback unless the queue is full.
    if !tq.TryDo(func() { fmt.Println("Done") }) {
        panic("queue is full")
    }

KeyTaskQueue

    // Create a KeyTaskQueue with a queue cap of 5 per key.
    ktq := taskqueue.NewKeyTaskQueue(5)

    // Add callbacks to be called sequentially, on different
	// goroutines for each key, in the queued order.
    ktq.Do("foo", func() { fmt.Println("First foo") })
    ktq.Do("foo", func() { fmt.Println("Second foo") })
    ktq.Do("bar", func() { fmt.Println("First bar") })

    // Add a callback unless the queue is full.
    if !ktq.TryDo("foo", func() { fmt.Println("Done") }) {
        panic("foo queue is full")
    }