package para

import "github.com/gohugoio/hugo/common/para"

Package para implements parallel execution helpers.

Index ¶

• type Runner
• type Workers
• func New(numWorkers int) *Workers
• func (w *Workers) Start(ctx context.Context) (Runner, context.Context)

Types ¶

type Runner ¶

type Runner interface {
	Run(func() error)
	Wait() error
}

Runner wraps the lifecycle methods of a new task set.

Run will block until a worker is available or the context is cancelled, and then run the given func in a new goroutine. Wait will wait for all the running goroutines to finish.

type Workers ¶

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

Workers configures a task executor with the most number of tasks to be executed in parallel.

func New ¶

func New(numWorkers int) *Workers

New creates a new Workers with the given number of workers.

func (*Workers) Start ¶

func (w *Workers) Start(ctx context.Context) (Runner, context.Context)

Start starts a new Runner.

Source Files ¶

para.go