work

Documentation

Index

• type Pool
  • func (p Pool) ParallelDo(tasks ...func() error) error

Types

type Pool

type Pool struct {
	Count int
}

func (Pool) ParallelDo

func (p Pool) ParallelDo(tasks ...func() error) error

ParallelDo Runs the given set of tasks in parallel using the configured number of worker go routines Will stop adding new tasks if a task throws an error, but will wait for in-flight tasks to finish