pool

package

v1.2.0 Latest Latest Go to latest Published: Aug 18, 2026 License: Apache-2.0 Imports: 4 Imported by: 0

Details

This section is empty.

View Source

var (
	ErrPoolTernimated = errors.New("pool is ternimated")
	ErrTimeout        = errors.New("timeout")
)

This section is empty.

type Handler[T any] interface {
	Handle(ctx context.Context, value T)
}

type HandlerFunc[T any] func(ctx context.Context, value T)

func (fn HandlerFunc[T]) Handle(ctx context.Context, value T)

type Pool[T any] struct {
	// contains filtered or unexported fields
}

func New[T any](size int, consumers int, handler Handler[T]) *Pool[T]

func (p *Pool[T]) Shutdown()

func (p *Pool[T]) Submit(ctx context.Context, timeout time.Duration, value T) error