pool

type Pool ¶

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

Pool executes tasks in order of their deadlines, using a fixed number of goroutines. Tasks are added to the pool with a function that returns the next deadline. The pool will execute the tasks in the order of their deadlines, ensuring that tasks with earlier deadlines are executed before those with later deadlines. If a task is added while the pool is waiting for the next task, it will wake up the waiting goroutine to process the new task immediately.

func New(workers int) *Pool

func (p *Pool) Add(fn func(context.Context) time.Time)