pool

Documentation

Index

• func NewPool(ctx context.Context, o Opts) *pond.WorkerPool
• type Opts

Functions

func NewPool

func NewPool(ctx context.Context, o Opts) *pond.WorkerPool

NewPool creates a fixed size (and buffered) go routine worker pool.

Types

type Opts

type Opts struct {
	Concurrency int
	QueueSize   int
}