# Functions
ExecuteInParallel will (in parallel) call the provided function with each item in the queue until the queue is exhausted.
New is a constructor for a new threadsafe queue.
NewAnyTrigger /工厂方法.
NewDailyTrigger /工厂方法.
/工厂方法.
NewNMinutesTrigger /工厂方法.
NewOneMinuteTrigger /工厂方法.
NewRingBuffer will allocate, initialize, and return a ring buffer with the specified size.
NewRoutinePool /工厂方法.
NewRunner returns a task runner.
NewTaskScheduler /工厂方法.
NewTimePointTrigger /工厂方法.
NewWithContext is a constructor for a new threadsafe queue.
# Constants
Cancelled job is cancelled.
Cancelling job is cancelling.
No description provided by the author
No description provided by the author
Failed job is failed when execute.
Finished job is complete.
No description provided by the author
Pending job is wait to running.
Running job is running.
# Variables
ErrDisposed is returned when an operation is performed on a disposed queue.
ErrEmptyQueue is returned when an non-applicable queue operation was called due to the queue's empty item state.
ErrJobCancelled errors job cancelled.
ErrTimeout is returned when an applicable queue operation times out.
No description provided by the author
No description provided by the author
No description provided by the author
# Structs
AnyTrigger /任意触发器.
Context /协程上下文.
DailyTrigger /每日周期性触发器.
/事件总线.
Job is do for something with state.
NMinutesTrigger /N分钟周期性触发器.
No description provided by the author
OneMinuteTrigger /1分钟周期性触发器.
Queue is the struct responsible for tracking the state of the queue.
RingBuffer is a MPMC buffer that achieves threadsafety with CAS operations only.
RoutinePool /协程池.
Runner TODO.
TaskParam /任务参数.
TaskScheduler /任务调度器.
TimePointTrigger /时间点触发.
# Type aliases
No description provided by the author
JobState is the job state.
TaskMethod /任务方法.