workerpool

package

v0.0.1 Latest Latest Go to latest Published: Mar 13, 2026 License: MIT Imports: 3 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Job[T any] struct {
	Handler StateHandler[T]
	Ctx     context.Context
	Data    T
}

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

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

func NewWorkerPool[T any](numWorkers int) *StatesPool[T]

NewWorkerPool initializes new instance of worker pool.

func (pool *StatesPool[T]) InsertJob(job Job[T])

func (pool *StatesPool[T]) RunWorkers()

RunWorkers runs workers which will be waiting for jobs to handle.

func (pool *StatesPool[T]) Shutdown()

Shutdown closes job channel and waits for all workers finished their works.

type WorkerPool[T any] interface {
	RunWorkers()
	Shutdown()
	InsertJob(job Job[T])
}