worker_pool

README

Worker pool

graph LR

subgraph Worker Pool
W1-->Task1
W2-->Task2
W3-->Task3
W4-->Task4
W5-->Task5
end
 
Task1-->Done
Task2-->Done
Task3-->Done
Task4-->Done
Task5-->Done
Done-->Result

TODO:

• Use sync.Pool or sync.Cond to manage workers
• Add Graceful Shutdown

References

Looking for Alternatives? Peek Here:

• https://github.com/panjf2000/ants

Documentation

Index

• type Result
• type Task
• type WP
• type Worker
  • func NewWorker(taskQueue <-chan Task, result chan<- Result) *Worker
• type WorkerPool
  • func New(workerNum int) *WorkerPool
  • func (wp *WorkerPool) Close()
  • func (wp *WorkerPool) Push(task ...Task)

Types

type Result

type Result struct {
	Value any
	Error error
}

type Task

type Task func() (any, error)

type WP

type WP interface {
	Push(task ...func()) error
}

type Worker

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

func NewWorker

func NewWorker(taskQueue <-chan Task, result chan<- Result) *Worker

type WorkerPool

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

func New

func New(workerNum int) *WorkerPool

func (*WorkerPool) Close

func (wp *WorkerPool) Close()

Close closes the task queue channel

func (*WorkerPool) Push

func (wp *WorkerPool) Push(task ...Task)