routine

package

v1.3.1 Latest Latest Go to latest Published: Jan 30, 2026 License: MIT Imports: 4 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func AsyncStreamPool[T any](workerCount, bufferSize int) *FactoryStreamPool[T]

func SyncStreamPool[T any](bufferSize int) *FactoryStreamPool[T]

func (f *FactoryStreamPool[T]) DisableAutoDrain() *FactoryStreamPool[T]

func (f *FactoryStreamPool[T]) EnableAutoDrain() *FactoryStreamPool[T]

func (f *FactoryStreamPool[T]) ForceExit() *FactoryStreamPool[T]

func (f *FactoryStreamPool[T]) GraceExit() *FactoryStreamPool[T]

func (f *FactoryStreamPool[T]) Make() *StreamPool[T]

type Job[T any] func(ctx context.Context) (T, error)

type JobError[T any] struct {
	Instance string
	Thread   int
	Error    error
}

type JobResult[T any] struct {
	Instance string
	Thread   int
	Output   T
}

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

func (p *StreamPool[T]) Done() <-chan struct{}

func (p *StreamPool[T]) Errors() <-chan JobError[T]

func (p *StreamPool[T]) Id(job Job[T]) string

func (p *StreamPool[T]) Results() <-chan JobResult[T]

func (p *StreamPool[T]) Stop() *StreamPool[T]

func (p *StreamPool[T]) Submit(job Job[T]) bool