executor

Sep 30, 2025

Changes in this version

+ func WithCapacity(capacity int) func(*Options)

type Executor

+ func New(policy FullBufferPolicy, poolSize int, optFns ...func(*Options)) (ex Executor)

+ func NewCallerBlocksOnFullExecutor(n int) Executor

+ type FullBufferPolicy int

+ const CallerBlocksOnFullPolicy

+ const CallerRunsOnFullPolicy

+ type Options struct

Sep 30, 2025

Changes in this version

+ var ErrClosed = errors.New("executor already closed")

+ type Executor interface

+ Close func() error

+ Execute func(func()) error

+ Wait func()

+ func NewCallerRunsOnFullExecutor(n int) Executor