pool

Documentation

Index

• Variables
• type CompletionFuture
• type Executor
  • func NewDynamicExecutor(maxNumberOfWorkers, queueDepth int, _options ...options.WithOption) Executor
  • func NewFixedSizeExecutor(numberOfWorkers, queueDepth int, _options ...options.WithOption) Executor
• type Runnable

Variables

var Canceled = errors.New("Canceled")

Canceled is returned on CompletionFuture.AwaitCompletion when a CompletionFuture was canceled

Types

type CompletionFuture

type CompletionFuture interface {
	AwaitCompletion(ctx context.Context) error
	Cancel(interrupt bool, err error)
}

type Executor

type Executor interface {
	io.Closer
	Start()
	Stop()
	Submit(ctx context.Context, workItemId int32, runnable Runnable) CompletionFuture
	IsRunning() bool
}

func NewDynamicExecutor

func NewDynamicExecutor(maxNumberOfWorkers, queueDepth int, _options ...options.WithOption) Executor

func NewFixedSizeExecutor

func NewFixedSizeExecutor(numberOfWorkers, queueDepth int, _options ...options.WithOption) Executor

type Runnable

type Runnable func()