qu

README

DS

Package qu is a executor service in golang.

You add your jobs to a list, then run them in parallel with a configurable amount of concurrency.

Usage

queue := &qu.Queue{}

job := func(payload interface{}) {
    // do something with your payload
}

// Add a job to the queue
queue.Add(job, "your payload")

// Run through the queue with 2 threads
queue.Run(2)

Documentation

Overview

Package qu is a executor service in golang.

You add your jobs to a list, then run them in parallel with a configurable amount of concurrency.

Index

• type Queue
  • func (q *Queue) Add(job func(payload interface{}), payload interface{})
  • func (q *Queue) Run(threads int)

Types

type Queue

type Queue struct {
	// contains filtered or unexported fields
}

Queue describes a queue of jobs

func (*Queue) Add

func (q *Queue) Add(job func(payload interface{}), payload interface{})

Add add a new job to the queue. Will be called with the given payload.

func (*Queue) Run

func (q *Queue) Run(threads int)

Run execute all jobs in the queue with the specified number of threads. Will block until all jobs have completed.