schedulex

package

v0.0.5 Latest Latest Go to latest Published: Jan 23, 2026 License: MIT Imports: 6 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type HeapTaskPool struct {
	sync.WaitGroup
	// contains filtered or unexported fields
}

func NewHeapTaskPool(now base.FNNow) *HeapTaskPool

func (tp *HeapTaskPool) AddTask(key string, t time.Time, exec TaskFunc, params ...interface{}) error

func (tp *HeapTaskPool) RemoveTask(key string) error

func (tp *HeapTaskPool) Start()

func (tp *HeapTaskPool) Stop()

type OpType int

type ScheduleTaskPool interface {
	AddTask(key string, t time.Time, exec TaskFunc, params ...any) error
	RemoveTask(key string) error

	Stop()
}

func CreateHeapTaskPool() ScheduleTaskPool

func CreateHeapTaskPoolWithFNNow(now base.FNNow) ScheduleTaskPool

type TaskFunc func(key string, args ...any)

Path	Synopsis
others
asynqx