work_queue

package

v1.4.1 Latest Latest Go to latest Published: Mar 15, 2024 License: MIT Imports: 3 Imported by: 0

Details

This section is empty.

View Source

var (
	MaxWorker = runtime.NumCPU()
	MaxQueue  = 100
)

View Source

var JobQueue chan Job

A buffered channel that we can send work requests on.

func Sample()

func WorkTest(params IJobParams) error

type Dispatcher struct {
	WorkerPool chan chan Job
	// contains filtered or unexported fields
}

func NewDispatcher(maxWorkers int) *Dispatcher

func (d *Dispatcher) Run()

type IJobParams interface {
	AddString(string, string)
	String(string) string
}

type Job struct {
	Payload func(IJobParams) error
	Data    *JobParams
}

Job represents the job to be run

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

func (j *JobParams) AddString(k string, v string)

func (j *JobParams) String(k string) string

type Worker struct {
	WorkerPool chan chan Job
	JobChannel chan Job
	// contains filtered or unexported fields
}

Worker represents the worker that executes the job

func NewWorker(workerPool chan chan Job) *Worker

func (w *Worker) Start()

Start method starts the run loop for the worker, listening for a quit channel in case we need to stop it

func (w *Worker) Stop()

Stop signals the worker to stop listening for work requests.