parallel

package

v0.3.11 Latest Latest Go to latest Published: Oct 2, 2026 License: BSD-3-Clause Imports: 8 Imported by: 0

Details

This section is empty.

This section is empty.

func CalculateThreadForTransferJob(fileSize int64, maxThreads int) int

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

func (job *ParallelJob) GetManager() *ParallelJobManager

func (job *ParallelJob) GetName() string

func (job *ParallelJob) GetWeight() int

func (job *ParallelJob) IsCanceled() bool

func (job *ParallelJob) Progress(taskType string, processed int64, total int64, errored bool)

func (job *ParallelJob) SetCanceled()

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

func NewParallelJobManager(weightCapacity int, showProgress bool, showFullPath bool, stopOnError bool) *ParallelJobManager

NewParallelJobManager creates a new ParallelJobManager

func (manager *ParallelJobManager) CancelJobs()

func (manager *ParallelJobManager) IsJobCanceled() bool

func (manager *ParallelJobManager) Schedule(name string, task ParallelJobTask, weight int, progressUnit progress.Units)

Schedule schedules a new job to run in parallel must be called before Start

func (manager *ParallelJobManager) Start() error

Start starts the job manager to run the scheduled jobs in parallel

type ParallelJobTask func(job *ParallelJob) error