dynamicworkerspool

README

dynamic_workers_pool

Dynamic workers pool

Documentation

Index

• type DynamicWorkersPool
  • func NewDynamicWorkersPool(workersNum, taskPoolSize uint) (*DynamicWorkersPool, error)
  • func (dwp *DynamicWorkersPool) Close() error
  • func (dwp *DynamicWorkersPool) PushTask(ctx context.Context, task func()) error
  • func (dwp *DynamicWorkersPool) ResetWorkersNum(workersNum uint) error

Types

type DynamicWorkersPool

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

DynamicWorkersPool пул воркеров с возможностью на ходу менять количество работающих воркеров

func NewDynamicWorkersPool

func NewDynamicWorkersPool(workersNum, taskPoolSize uint) (*DynamicWorkersPool, error)

NewDynamicWorkersPool создает пул воркеров

func (*DynamicWorkersPool) Close

func (dwp *DynamicWorkersPool) Close() error

Close - закрывает пул и ждет пока все воркеры доработают После закрытия пул не пригоден для работы, при попытке добавить задание упадет с паникой

func (*DynamicWorkersPool) PushTask

func (dwp *DynamicWorkersPool) PushTask(ctx context.Context, task func()) error

PushTask - добавляет задачу в очередь. PushTask блокирующая операция, и стоит использовать context.WithCancel/context.WithTimeout

func (*DynamicWorkersPool) ResetWorkersNum

func (dwp *DynamicWorkersPool) ResetWorkersNum(workersNum uint) error

ResetWorkersNum переопределение числа воркеров