threads

Documentation

Index

• type Engine
  • func NewEngine(maxWorkers int) *Engine
  • func (e *Engine) AddTask(task Task)
  • func (e *Engine) Start()
  • func (e *Engine) Stop()
• type Task

Types

type Engine

type Engine struct {
	// contains filtered or unexported fields
}

Engine manages a pool of workers to execute tasks concurrently.

func NewEngine

func NewEngine(maxWorkers int) *Engine

NewEngine initializes a new Engine with a logger and an optimal number of workers.

func (*Engine) AddTask

func (e *Engine) AddTask(task Task)

AddTask adds a new task to the task channel, scaling workers if necessary.

func (*Engine) Start

func (e *Engine) Start()

Start launches the initial set of worker goroutines.

func (*Engine) Stop

func (e *Engine) Stop()

Stop gracefully shuts down the engine by closing the task channel and waiting for all workers to finish.

type Task

type Task func()

Task represents a unit of work to be executed by the engine.