Versions in this module Expand all Collapse all v0 v0.1.11 Oct 3, 2023 v0.1.10 Oct 2, 2023 Changes in this version + func WithMaxQueueSize(maxSize int) options.Option[Executor] + func WithMaxSize(maxSize int) options.Option[Queue] + type Executor struct + func NewExecutor(workerCount int, opts ...options.Option[Executor]) (timedExecutor *Executor) + func (t *Executor) ExecuteAfter(f func(), delay time.Duration) *ScheduledTask + func (t *Executor) ExecuteAt(f func(), time time.Time) *ScheduledTask + func (t *Executor) Shutdown(optionalShutdownFlags ...ShutdownFlag) + func (t *Executor) Size() int + func (t *Executor) WorkerCount() int + type HeapKey time.Time + func (t HeapKey) CompareTo(other HeapKey) int + type Queue struct + func NewQueue(opts ...options.Option[Queue]) (queue *Queue) + func (t *Queue) Add(value any, scheduledTime time.Time) (addedElement *QueueElement) + func (t *Queue) IsShutdown() bool + func (t *Queue) Poll(waitIfEmpty bool) any + func (t *Queue) Shutdown(optionalShutdownFlags ...ShutdownFlag) + func (t *Queue) Size() int + type QueueElement struct + Value any + func (timedQueueElement *QueueElement) Cancel() + type ScheduledTask = QueueElement + type ShutdownFlag = bitmask.BitMask + const CancelPendingElements + const DontWaitForShutdown + const IgnorePendingTimeouts + const PanicOnModificationsAfterShutdown + type TaskExecutor struct + func NewTaskExecutor(workerCount int) *TaskExecutor[T] + func (t *TaskExecutor[T]) Cancel(identifier T) (canceled bool) + func (t *TaskExecutor[T]) ExecuteAfter(identifier T, callback func(), delay time.Duration) *ScheduledTask + func (t *TaskExecutor[T]) ExecuteAt(identifier T, callback func(), executionTime time.Time) *ScheduledTask
Go to main page