Function New

workers/workers.go:22–39

New creates new semaphores instance

(config *Config)

// New creates new semaphores instance
func New(config *Config) (*Workers, error) {
	if err := config.Validate(); err != nil {
		return nil, err
	}

	var queue *semaphore.Weighted

	if config.RequestsQueueSize > 0 {
		queue = semaphore.NewWeighted(int64(config.RequestsQueueSize + config.WorkersNumber))
	}

	workers := semaphore.NewWeighted(int64(config.WorkersNumber))

	return &Workers{
		queue:   queue,
		workers: workers,
	}, nil
}

// Acquire acquires a worker.
// It returns a worker release function and an error if any.