Versions in this module Expand all Collapse all v0 v0.1.1 Aug 28, 2026 v0.1.0 Aug 24, 2026 Changes in this version + func CountPrimesParallel(ctx context.Context, lo, hi int, cfg poolConfig) (int, error) + type LFdeque struct + func NewLFdeque[T any](capacity int) *LFdeque[T] + func (d *LFdeque[T]) Len() int64 + func (d *LFdeque[T]) PopBottom() (v T, ok bool) + func (d *LFdeque[T]) PushBottom(v T) + func (d *LFdeque[T]) PushSliceBottom(v []T) + func (d *LFdeque[T]) Steal() (v T, ok bool) + func (d *LFdeque[T]) StealHalf() (v []T, ok bool) + type Task func(ctx context.Context, item T, spawn func(T)) (result *R, err error) + type Worker struct + type WorkerPool struct + func NewWorkerPool[T, R any](ctx context.Context, poolSize, initialWorkerCap, resultBuffSize int, ...) WorkerPool[T, R] + func (p *WorkerPool[T, R]) Run() <-chan R + func (p *WorkerPool[T, R]) StealHalf(thiefIdx int) (ok bool) + func (p *WorkerPool[T, R]) Submit(item T) + func (p *WorkerPool[T, R]) Wait() error
Go to main page