Method SetThreads

internal/utils/fs/limiter.go:42–56

(newThreads int)

}

func (this *Limiter) SetThreads(newThreads int) {
	if newThreads <= 0 {
		newThreads = this.countDefault
	}

	if newThreads != this.count {
		var threadsChan = make(chan struct{}, newThreads)
		for i := 0; i < newThreads; i++ {
			threadsChan <- struct{}{}
		}

		this.threads = threadsChan
		this.count = newThreads
	}
}

func (this *Limiter) Ack() {
	<-this.threads