queue

Documentation

Index

• func Start(workers int, jobs <-chan Job, results chan<- Result)
• type Job
• type Jobs
• type Result
• type Results

Functions

func Start

func Start(workers int, jobs <-chan Job, results chan<- Result)

Start creates worker goroutines and starts waiting for jobs to come through. Close the jobs channel to stop the queue, all existing jobs will be processed. After all workers have finished, the results channel will be closed.

Types

type Job

type Job interface {
	Run() Result
}

type Jobs

type Jobs chan Job

type Result

type Result interface {
	Err() error
}

type Results

type Results chan Result