workerjuice

Documentation

Index

• type PoolInterface
  • func NewPool(poolSize uint) PoolInterface
• type SemaphoreInterface
  • func NewSemaphore(concurrency int) SemaphoreInterface
• type Task

Types

type PoolInterface

type PoolInterface interface {
	RunTaskChannel(tasks <-chan Task)
	CreateTaskChannel() <-chan Task
	CloseTaskChannel(tasks chan Task)
	Close()
	Errors() <-chan error
	Wait()
}

PoolInterface represents the interface that a worker pool should implement.

func NewPool

func NewPool(poolSize uint) PoolInterface

NewPool creates a new Pool with the specified size.

type SemaphoreInterface

type SemaphoreInterface interface {
	Acquire()
	Release()
	Wait()
}

func NewSemaphore

func NewSemaphore(concurrency int) SemaphoreInterface

type Task

type Task func() error

Task represents a task that can be added to a Pool.