worker

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

type OptimizedPoolConfig struct {
	MinWorkers         int
	MaxWorkers         int
	QueueSize          int
	IdleTimeout        time.Duration
	ScaleUpThreshold   float64 // Queue utilization threshold to scale up
	ScaleDownThreshold float64 // Queue utilization threshold to scale down
	MetricsEnabled     bool
}

type OptimizedPoolStats struct {
	ActiveWorkers    int64         `json:"active_workers"`
	TotalWorkers     int64         `json:"total_workers"`
	TasksSubmitted   int64         `json:"tasks_submitted"`
	TasksCompleted   int64         `json:"tasks_completed"`
	TasksFailed      int64         `json:"tasks_failed"`
	TasksPending     int           `json:"tasks_pending"`
	QueueCapacity    int           `json:"queue_capacity"`
	QueueUtilization float64       `json:"queue_utilization"`
	AvgWaitTime      time.Duration `json:"avg_wait_time"`
	AvgExecTime      time.Duration `json:"avg_exec_time"`
}

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

type Stats struct {
	PoolSize int   `json:"pool_size"`
	Running  int   `json:"running"`
	Total    int64 `json:"total"`
}

type Task struct {
	ID       string
	Fn       func(context.Context) error
	Priority int
	Timeout  time.Duration
}

type TaskResult struct {
	TaskID   string
	Error    error
	Duration time.Duration
}