package
1.0.0-rc.3
Repository: https://github.com/iotaledger/hive.go.git
Documentation: pkg.go.dev

# Functions

NewExecutor is the constructor for a timed Executor that creates a scheduler with a given number of workers that execute the scheduled tasks in parallel (whenever they become due).
NewQueue is the constructor for the timed Queue.
NewTaskExecutor is the constructor of the TaskExecutor.
WithMaxQueueSize is an ExecutorOption for the TimedExecutor that allows to specify a maxSize of the underlying queue.
WithMaxSize is an Option for the timed.Queue that allows to specify a maxSize of the queue.

# Constants

CancelPendingElements defines a shutdown flag, that causes the queue to be emptied on shutdown.
DontWaitForShutdown causes the TimedExecutor to not wait for all tasks to be executed before returning from the Shutdown method.
IgnorePendingTimeouts defines a shutdown flag, that makes the queue ignore the timeouts of the remaining queued elements.
PanicOnModificationsAfterShutdown makes the queue panic instead of ignoring consecutive writes or modifications.

# Structs

Executor defines a scheduler that executes tasks in the background at a given time.
Queue represents a queue, that holds values that will only be released at a given time.
QueueElement is an element in the TimedQueue.
TaskExecutor is a TimedExecutor that internally manages the scheduled callbacks as tasks with a unique identifier.

# Type aliases

No description provided by the author
ScheduledTask is.
ShutdownFlag defines the type of the optional shutdown flags.