Function NewWorkerPool

internal/download/pool.go:60–78

(progressCh chan<- any, maxDownloads int)

)

func NewWorkerPool(progressCh chan<- any, maxDownloads int) *WorkerPool {
	if maxDownloads < 1 {
		maxDownloads = 3 // Default to 3 if invalid
	}
	pool := &WorkerPool{
		taskChan:         make(chan string, 100), // We make it buffered to avoid blocking add
		progressCh:       progressCh,
		progressDone:     make(chan struct{}),
		downloads:        make(map[string]*activeDownload),
		queued:           make(map[string]types.DownloadConfig),
		maxDownloads:     maxDownloads,
		globalLimiter:    engine.NewRateLimiter(0, 0),
		downloadLimiters: make(map[string]*engine.RateLimiter),
	}
	for i := 0; i < maxDownloads; i++ {
		go pool.worker()
	}
	return pool
}

// syncConfigFromState syncs Filename, DestPath, and Mirrors from the associated state.
func syncConfigFromState(cfg *types.DownloadConfig) {