worker

README

Sync / Async serial worker queue (GCD)

basic functionality you would expect from: https://developer.apple.com/reference/dispatch

builds

example

GCD style serial execution of function (lambdas / blocks)

  import "github.com/korovkin/worker"
  ...

  w := worker.NewWorkerDefault("test")
  for i := 0; i < 1000; i++ {
    i := i
    worker.Enqueue(func() {
        fmt.Println(" async: i:", i)
    })
  }
  worker.EnqueueSync(func() {
      fmt.Println("sync!")
  })

Documentation

Index

• type Worker
  • func NewWorker(name string, queue chan WorkerJob) *Worker
  • func NewWorkerDefault(name string) *Worker
  • func (w *Worker) Close()
  • func (w *Worker) Enqueue(job func())
  • func (w *Worker) EnqueueSync(job func())
  • func (w *Worker) GetQueueSize() int
  • func (w *Worker) Stop(job func())
• type WorkerJob

Types

type Worker

type Worker struct {
	Name string
	// contains filtered or unexported fields
}

func NewWorker

func NewWorker(name string, queue chan WorkerJob) *Worker

func NewWorkerDefault

func NewWorkerDefault(name string) *Worker

func (*Worker) Close

func (w *Worker) Close()

func (*Worker) Enqueue

func (w *Worker) Enqueue(job func())

func (*Worker) EnqueueSync

func (w *Worker) EnqueueSync(job func())

func (*Worker) GetQueueSize

func (w *Worker) GetQueueSize() int

func (*Worker) Stop

func (w *Worker) Stop(job func())

type WorkerJob

type WorkerJob struct {
	Job func()
	// contains filtered or unexported fields
}