parallel

README

go-parallel

Documentation

Index

• type JobPool
  • func CustomJobPool(config JobPoolConfig) *JobPool
  • func LargeJobPool() *JobPool
  • func MediumJobPool() *JobPool
  • func SmallJobPool() *JobPool
  • func (jp *JobPool) AddJob(job func()) error
  • func (jp *JobPool) Close()
  • func (jp *JobPool) Wait() error
  • func (jp *JobPool) WaitContext(ctx context.Context) error
• type JobPoolConfig

Types

type JobPool

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

func CustomJobPool

func CustomJobPool(config JobPoolConfig) *JobPool

func LargeJobPool

func LargeJobPool() *JobPool

func MediumJobPool

func MediumJobPool() *JobPool

func SmallJobPool

func SmallJobPool() *JobPool

func (*JobPool) AddJob

func (jp *JobPool) AddJob(job func()) error

func (*JobPool) Close

func (jp *JobPool) Close()

func (*JobPool) Wait

func (jp *JobPool) Wait() error

func (*JobPool) WaitContext

func (jp *JobPool) WaitContext(ctx context.Context) error

type JobPoolConfig

type JobPoolConfig struct {
	WorkerCount  int
	JobQueueSize int
}