worker

package
v0.0.0-...-30f8b58 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 11, 2019 License: MIT Imports: 3 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Job

type Job interface {
	Process()
}

type Worker

type Worker struct {
	sync.WaitGroup

	Blocking   bool
	Concurrent bool
	// contains filtered or unexported fields
}

func New

func New() *Worker

func (*Worker) Count

func (w *Worker) Count() int

func (*Worker) Process

func (w *Worker) Process()

func (*Worker) Queue

func (w *Worker) Queue(job Job)

func (*Worker) QueueAndProcess

func (w *Worker) QueueAndProcess(job Job)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL